我的经验与集团重新平衡需要很长的时间,所以它是阻止任何消费者消费信息。我的问题:
为什么要花这么多时间来调整集团的平衡?
如何解决此问题?我需要重启kafka集群吗?或者任何解决方案,因为我们正在生产中使用kafka集群
以下是截图:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9095 --new-consumer --describe --group command-consumer-ldnpsr000001135 --command-config config/consumer.config
Consumer group `command-consumer-ldnpsr000001135` is rebalancing.
谢谢你的建议?
1条答案
按热度按时间thtygnil1#
有两个可能的原因:
当消费者加入一个群体时,就会开始一个重新平衡的过程。重试次数有一个配置:rebalance.max.retries,默认设置为4。
如果消费者没有心跳到zookeeper。zookeeper会话超时。Zookeeper在这段时间内,它被认为是死的,一个重新平衡将发生。