springboot集成kafka的简单示例
时间: 2023-08-21 22:03:05 浏览: 116
引用\[1\]是一个简单的Spring Boot集成Kafka的示例代码,其中定义了一个KafkaProducer类,使用@Autowired注解注入了KafkaTemplate对象,通过调用kafkaTemplate的send方法来发送消息到名为"topic1"的Kafka主题。\[1\]
引用\[2\]是示例代码中引入了Spring Kafka的依赖,可以在项目的pom.xml文件中添加该依赖来使用Spring Kafka。\[2\]
引用\[3\]是示例代码中连接Kafka的配置,其中advertised.listeners配置了Kafka的公网IP和端口号。在实际项目中,需要根据实际情况修改该配置。\[3\]
综上所述,以上是一个简单的Spring Boot集成Kafka的示例,通过引入Spring Kafka的依赖和配置Kafka连接信息,可以使用KafkaTemplate发送消息到指定的Kafka主题。
#### 引用[.reference_title]
- *1* *2* *3* [SpringBoot集成kafka全面实战](https://blog.csdn.net/weixin_70730532/article/details/125425798)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insertT0,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]
阅读全文