spring boot kafka 发送消息完整的例子工程

本文介绍: 以上是一个简单的Spring Boot Kafka发送消息的完整例子。你可以根据自己的需求进行修改和扩展。

以下是一个简单的Spring Boot Kafka发送消息的完整例子：

首先，添加Spring Boot Kafka的依赖到你的pom.xml文件：

xml
<dependencies>  
    <dependency>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-starter-kafka</artifactId>  
    </dependency>  
</dependencies>

在application.properties文件中配置Kafka的相关属性：

properties
spring.kafka.bootstrap-servers=localhost:9092  
spring.kafka.consumer.group-id=test-group  
spring.kafka.template.default-topic=test-topic

创建一个Kafka生产者类，并注入KafkaTemplate：

java
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.kafka.core.KafkaTemplate;  
import org.springframework.stereotype.Service;  
  
@Service  
public class KafkaProducerService {  
    @Autowired  
    private KafkaTemplate<String, String> kafkaTemplate;  
  
    public void sendMessage(String message) {  
        kafkaTemplate.send("test-topic", message);  
    }  
}

在你的Spring Boot应用程序中，你可以调用sendMessage方法发送消息：

java
@Autowired  
private KafkaProducerService kafkaProducerService;  
  
public static void main(String[] args) {  
    SpringApplication.run(MyApplication.class, args);  
    KafkaProducerService kafkaProducerService = SpringApplicationContext.getBean(KafkaProducerService.class);  
    kafkaProducerService.sendMessage("Hello, Kafka!");  
}

以上是一个简单的Spring Boot Kafka发送消息的完整例子。你可以根据自己的需求进行修改和扩展。

原文地址:https://blog.csdn.net/baobaopizi/article/details/135749824

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。

如若转载，请注明出处：http://www.7code.cn/show_62549.html

如若内容造成侵权/违法违规/事实不符，请联系代码007邮箱：suwngjj01@126.com进行投诉反馈，一经查实，立即删除！

主题授权提示：请在后台主题设置-主题授权-激活主题的正版授权，授权购买：RiTheme官网

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。