apache-kafka - 卡夫卡消费者卡在(重新)加入组中

Question

如果 kafka(版本 0.10)消费者尝试重新加入消费者组，它的默认行为是什么。
我正在为一个消费者组使用单个消费者，但似乎重新加入时受到了打击。
每 10 分钟后，它会在消费者日志中打印以下行。

2016-08-11 13:54:53,803 INFO o.a.k.c.c.i.ConsumerCoordinator [pool-5-thread-1] ****Revoking previously assigned partitions**** [] for group image-consumer-group

2016-08-11 13:54:53,803 INFO o.a.k.c.c.i.AbstractCoordinator [pool-5-thread-1] (Re-)joining group image-consumer-group

2016-08-11 14:04:53,992 INFO o.a.k.c.c.i.AbstractCoordinator [pool-5-thread-1] Marking the coordinator dead for group image-consumer-group

2016-08-11 14:04:54,095 INFO o.a.k.c.c.i.AbstractCoordinator [pool-5-thread-1] Discovered coordinator for group image-consumer-group.

2016-08-11 14:04:54,096 INFO o.a.k.c.c.i.AbstractCoordinator [pool-5-thread-1] (Re-)joining group image-consumer-group

重新启动消费者应用程序没有帮助。

Answer 1

如果您打算在一组中只有一个消费者实例，请使用带有手册 assignment 的消费者。战略。 (简单消费者)。

手动主题分配不使用消费者的组管理功能，因此不需要心跳。