apache-kafka - kafka集群中的多个消费者
问题描述
我有一个 kakfa 主题,它有 10 个分区,我有 2 个具有相同组的消费者,如下面的 消费者 1
@KafkaListener(topics = "topic2", groupId = "group_id",containerFactory="jsonKafkaListenerContainerFactory")
public void consume(Person person) {}
消费者2
@KafkaListener(topics = "topic2", groupId = "group_id",containerFactory="jsonKafkaListenerContainerFactory")
public void consume(Person person) {}
如果我想增加消费者说 10,那么我是否需要创建我的方法(消费)的副本以创建更多消费者,或者我们是否还有其他选择。
解决方案
推荐阅读
- python - 如何按升序浏览目录中的文件
- javascript - 如何修复车把中的前端 javascript 从服务器捕获未定义的值?
- r - 将列读取为范围以比较值
- node.js - MetaMask Web3 以太坊未定义
- c - 无法更新程序中的项目配置变量
- tensorflow - TensorFlow Keras SavedModel 空变量文件夹
- unit-testing - 如何模拟 IdentityServerDbContext 以添加 ApplicationUser
- c++ - 2 的补码二进制预期输出
- assembly - 我试图理解“rep scasb byte [edi]”指令
- elasticsearch - ELK docker image 观察到数组中的对象没有得到很好的支持错误