Wie bekomme ich Kafka Lag mit Kafka 0.10?

Question

Da Kafka 0.10 Zookeeper nicht mehr zum Speichern der Verzögerungen verwendet, wie kann ich es jetzt abrufen? Gibt es eine Möglichkeit, von den Verbrauchern darauf zuzugreifen?

Answer 1

Laut der aktuellen Dokumentation:

> 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 

Answer 2

Kafka 0.10.0.x: kafka.apache.org/documentation wird die folgende Art und Weise getan

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group your_consumer_group 

Kafka 0.9 oder früher:

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group your_consumer_group --topic your_topic