如何使用Kafka 0.10获得Kafka滞后？

Question

由于Kafka 0.10不再使用Zookeeper来存储滞后,我现在如何检索它？有没有办法从消费者那里获取它？

Answer 1

根据最新文档:kafka.apache.org/documentation,它按以下方式完成:

> bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --describe --group test-consumer-group

  TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG        CONSUMER-ID                                       HOST                           CLIENT-ID
  test-foo                       0          1               3               2          consumer-1-a5d61779-4d04-4c50-a6d6-fb35d942642d   /127.0.0.1                     consumer-1