kafka使用

框架: spring-kafka 1.2.2

生产者端代码

说明:

bootstrapServers: kafka 地址

kafkaTemplate: 服务调用模板

消费端代码:

说明:

@EnableKafka : 开启kafka

bootstrapServers: kafka 地址

groupIdConfig: 群组名称

consumerConfigs(): 客户端配置

consumerFactory():客户端工厂

kafkaListenerContainerFactory(): 配置kafka监听工厂

实际使用:

发送消息:


指定话题和内容,框架会发送到对应的话题

接收消息:

使用

@KafkaListener 注解并加上对应的话题,就可以自动接收相应的消息

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容