跨机器/流程在卡夫卡扩大消费者

Question

如果我想通过启动运行我的消费者代码的新机器/流程来扩大我的消费者到特定主题，是否让消费者（在所有机器/进程）使用相同的消费者组ID？卡夫卡会处理所有的协调？

（假设有超过消费者的话题在多个分区）

只是想确认一下我的理解。

Answer 1

是的，就这么简单！

当消费者加入或离开消费者群体时，他们会自动在Zookeeper上注册自己，这反过来会触发一个在新消费者池中重新分配负载的进程。