架构师_程序员_码农网

 找回密码
 注册[Register]

QQ登录

只需一步,快速开始

查看: 8560|回复: 0

[资料] Spring Boot 动态设置 Kafka 的 Topic 或 GroupId

[复制链接]
发表于 2021-11-14 20:03:45 | 显示全部楼层 |阅读模式
在集群部署微服务的时候,如果我们想给所有的应用下发指令,可以将应用订阅 Kafka 的 topic,但是需要注意的是,对于同一个 topic 需要设置不同的 groupid,才能使一条消息被所有的应用接收到。

使用 docker 搭建 Kafka  应用,命令如下:

注意:请将 192.168.1.166 替换成自己的实际 ip 地址

pom.xml 引入 spring-kafka 包,如下:


自定义 Kafka 消费者配置,新建 KafkaConsumer 文件,如下:


新建一个消费者 ConfigConsumer,该消费者默认配置:topic:defaultTopic,groupid:defaultGroupId,代码如下:

application.properties 配置 Kafka 的地址:


启动项目,应用订阅是默认的配置,如下:

QQ截图20211114194536.jpg

KafkaMessageListenerContainer 继承了 AbstractMessageListenerContainer 抽象类,在 createSimpleLoggingConsumerRebalanceListener 方法会输出消费者的 groupid 和 topic、partition。

2021-11-14 19:44:26.689  INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : defaultGroupId: partitions assigned: [defaultTopic-0]
动态设置 topic 和 groupid,项目启动命令如下:

QQ截图20211114194650.jpg

动态设置的 topic 为:a1,groupid为:itsvse.com

2021-11-14 19:46:25.330  INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : itsvse.com: partitions assigned: [a1-0]
Spring 覆盖 jar 包内的默认配置
https://www.itsvse.com/thread-10129-1-1.html

(完)





上一篇:MySQL SQL 性能优化之慢查询
下一篇:Spring Boot Kafka 重启丢弃旧数据
码农网,只发表在实践过程中,遇到的技术难题,不误导他人。
您需要登录后才可以回帖 登录 | 注册[Register]

本版积分规则

免责声明:
码农网所发布的一切软件、编程资料或者文章仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版软件,购买注册,得到更好的正版服务。如有侵权请邮件与我们联系处理。

Mail To:help@itsvse.com

QQ|手机版|小黑屋|架构师 ( 鲁ICP备14021824号-2 )|网站地图

GMT+8, 2024-3-29 22:04

Powered by Discuz! X3.4

Copyright © 2001-2021, Tencent Cloud.

快速回复 返回顶部 返回列表