【问题标题】: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
    

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2017-08-30
      • 2017-02-20
      • 2016-12-25
      • 2017-11-07
      • 1970-01-01
      • 2019-06-20
      • 2018-12-14
      • 1970-01-01
      相关资源
      最近更新 更多