如何检查 Kafka 滞后到 kafka 版本 2.11-0.11.0.0 的主题
How to Check Kafka Lag into topics for kafka version 2.11-0.11.0.0
我使用的是 kafka 版本 2.10-0.9.0.1，所有信息都会发送给 zookeeper，所以我使用以下命令来检查 kafka 延迟：
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group
group-name --topic topicName --zookeeper zooIp:2181
现在我们使用的是最新的kafka版本2.11-0.11.0.0，这里这个命令不起作用。
我们如何看待主题的卡夫卡滞后。
偏移量不再存储在 Zookeeper 中，而是直接存储在 Kafka 中。
您可以使用 kafka-consumer-groups 工具 (kafka.admin.ConsumerGroupCommand) 检索组的 position/lag。
bin/kafka-consumer-groups.sh --bootstrap-server KAFKA_HOST:KAFKA_PORT --describe --group GROUP_NAME
我使用的是 kafka 版本 2.10-0.9.0.1，所有信息都会发送给 zookeeper，所以我使用以下命令来检查 kafka 延迟：
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group group-name --topic topicName --zookeeper zooIp:2181
现在我们使用的是最新的kafka版本2.11-0.11.0.0，这里这个命令不起作用。 我们如何看待主题的卡夫卡滞后。
偏移量不再存储在 Zookeeper 中，而是直接存储在 Kafka 中。
您可以使用 kafka-consumer-groups 工具 (kafka.admin.ConsumerGroupCommand) 检索组的 position/lag。
bin/kafka-consumer-groups.sh --bootstrap-server KAFKA_HOST:KAFKA_PORT --describe --group GROUP_NAME