kafka消费需要换一个groupid才可以

Question

今天测试消费使用了group.id为test的组，一开始能正常消费信息，过了一段时间发现无法消费信息，一直在提示(Re-)joining group，请问这种情况该如何处理呢，是什么原因造成的

Answer 1

Allen 2021-07-23 10:53:40

看错误是做了group的重分配了， 有其他的消费者加入么

• 提问者 qq_我来野ty_vGMT02 #1

  并没有我，实际上，从控制移到多个分区代码运行后，consumer再次运行就会报这个错，把kafka重启，代码显示订阅方式是consumer.subscribe(Arrays.asList(TOPIC_NAME));也是一样，只有一个partition能消费到

• Allen 回复 提问者 qq_我来野ty_vGMT02 #2

  现在kafka的topic情况，partition情况，consumer启动了多少个节点，producer启动了多少节点，都大概描述一下呗