【问题标题】:How to Check Kafka Lag into topics for kafka version 2.11-0.11.0.0如何将 Kafka Lag 检查到 kafka 版本 2.11-0.11.0.0 的主题中
【发布时间】:2018-01-04 18:42:27
【问题描述】:
我使用的是 kafka 版本 2.10-0.9.0.1,所有信息都转到 zookeeper,所以我使用以下命令检查 kafka Lag:
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group
组名 --topic 主题名 --zookeeper zooIp:2181
现在我们使用最新的 kafka 版本 2.11-0.11.0.0,这里这个命令不起作用。
我们如何看待主题的 kafka 滞后。
【问题讨论】:
标签:
apache-kafka
apache-zookeeper
【解决方案1】:
偏移量不再存储在 Zookeeper 中,而是直接存储在 Kafka 中。
您可以使用kafka-consumer-groups 工具 (kafka.admin.ConsumerGroupCommand) 检索组的位置/滞后。
bin/kafka-consumer-groups.sh --bootstrap-server KAFKA_HOST:KAFKA_PORT --describe --group GROUP_NAME