卡夫卡消费者陷入(重新)加入集团

Question

什么是kafka(版本0.10)使用者的默认行为,如果它尝试重新加入使用者组.我正在为一个消费者群体使用单个消费者,但看起来它重新加入了.每10分钟后,它会在消费者日志中打印以下行.

2016-08-11 13:54:53,803 INFO oakcciConsumerCoordinator [pool-5-thread-1]****撤销之前为group image-consumer-group分配的分区****[]

2016-08-11 13:54:53,803 INFO oakcciAbstractCoordinator [pool-5-thread-1] (重新)加入群组形象 - 消费群体

2016-08-11 14:04:53,992 INFO oakcciAbstractCoordinator [pool-5-thread-1]将协调员标记为群组图像 - 消费者群体

2016-08-11 14:04:54,095 INFO oakcciAbstractCoordinator [pool-5-thread-1]发现了group image-consumer-group的协调员.

2016-08-11 14:04:54,096 INFO oakcciAbstractCoordinator [pool-5-thread-1] (Re-)加入group image-consumer-group

重启消费者应用程序没有帮助.

Answer 1

如果您打算在一组中只有一个消费者实例，则使用具有手动assignment策略的消费者。（简单消费者）。

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