首页 > 基础资料 博客日记
KafKa动态分组ID
2024-10-29 11:30:02基础资料围观261次
这篇文章介绍了KafKa动态分组ID,分享给大家做个参考,收藏Java资料网收获更多编程知识
背景说明:
做这个的原因主要是因为懒,KafKa监听没有独立项目出去,由于KafKa没有组内广播模式,这就造成了一个问题:项目多处启动的时候,就只有一个地方能接收信息。这个时候就要手懂修改分组ID了。
原理说明:
采用一些语法,使用动态的配置。
代码如下:

@KafkaListener(id = "#{@kafkaBean.groupId}", topics = "test-topics") public void deviceMessage(String message) { //业务处理部分 }

@Bean("kafkaBean") public KafkaBean kafkaBean() { return new KafkaBean(); }

public class KafkaBean { public String groupId = IdUtil.simpleUUID(); }
代码说明:
其实就是每次在实体中生成心的groupId,我这里就比较偷懒也不管性能了。其实可以采用读取机器码的或者IP来取代我这里的随机值。
文章来源:https://www.cnblogs.com/tangzeqi/p/18512526
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:jacktools123@163.com进行投诉反馈,一经查实,立即删除!
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:jacktools123@163.com进行投诉反馈,一经查实,立即删除!
标签:
相关文章
最新发布
- hot100之普通数组
- 记一次诡异的线上异常赋值排查:代码没错,结果不对
- hot100之子串
- 剑指offer-1、⼆维数组中的查找
- 从尾到头打印链表
- 秒杀/高并发解决方案+落地实现 (技术栈: SpringBoot+Mysql + Redis +RabbitMQ +MyBatis-Plus +Maven + Linux + Jmeter ) -03
- @ModelAttribute、@RequestBody、@RequestParam、@PathVariable 注解对比
- Java 样板代码库 Lombok 使用详解
- wso2~自定义event-publisher
- 数组数量数据数量大 1000万黑名单用户 一百亿基础用户 查询检索思路