返回到文章

采纳

编辑于 4年前

kafka滚动重启几台broker后,某些消费者换group才能消费

kafka

重启了一个集群的部分broker后,部分消费者报错:

kafka server: Request was for a consumer group that is not coordinated by this broker. groupID=XXXXX

同时伴随着reblance的报错。

broker版本是0.10.2.1

这个问题遇到过多次了,尝试过再次重启、迁移主从,虽然更换group后可以正常消费,换group会重复消费大量数据,想知道有没有能让原group恢复消费的方法