首页 文章

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

提问于
浏览
5

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

2016-08-11 13:54:53,803 INFO oakcciConsumerCoordinator [pool-5-thread-1] 撤销以前分配的分区 [] for group image-consumer-group 2016-08-11 13 :54:53,803 INFO oakcciAbstractCoordinator [pool-5-thread-1](Re-)加入group image-consumer-group 2016-08-11 14:04:53,992 INFO oakcciAbstractCoordinator [pool-5-thread-1] Marking group image-consumer-group的协调员死了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 o.a.k.c.c.i.AbstractCoordinator [pool-5-thread-1](重新)加入群组形象 - 消费群体

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

1 回答

  • 1

    如果您要在一个组中只有一个消费者实例,那么请使用具有手动 assignment 策略的消费者 . (简单消费者) .

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

相关问题