我们使用Kafka2.1.0,请帮助我了解在Kafka日志中看到以下消息时的实际情况:
Preparing to rebalance group some-service in state PreparingRebalance with old generation 21668
(__consumer_offsets-47) (reason: removing member consumer-24-f5b9a9b1-ffed-4088-999b-378df9aaa71b on LeaveGroup)
(kafka.coordinator.group.GroupCoordinator)
这是否表明kafka从组中移除了一个消费者(由于超时或其他原因)或消费者离开了组本身?
1条答案
按热度按时间mccptt671#
发生这种情况的原因是消费者不能正常工作,并且不能通过超时向经纪人作出回应