我有一个组Id“我-消费者组-id”和3个主题与他们自己的消费者说。
"my-consumer-1" consumed to "topic1" with groupId "my-consumer-group-id"
"my-consumer-2" consumed to "topic2" with groupId "my-consumer-group-id"
"my-consumer-3" consumed to "topic3" with groupId "
我需要澄清重新平衡如何影响同一群体的消费者,但他们订阅了Kafka 0.10.1中的不同主题regex。
假设我们有三个卡夫卡消费者c1,c2和c3。他们分别订阅了主题*_t1、*_t2和*_t3。现在,让我们把所有这些消费者放在同一个消费者群体中,my-consumer说。在这个场景中,如果在c2中添加了新的主题,*_t1和c3会参与再平衡吗?
我查阅了卡夫卡文档并找到了一些相关信息。第二点明确指出,消费者:
Register a watch on changes (new consumers joining or any existing consumers leaving) under