当偏移存储是Kafka时如何检查消费者偏移? [英] How to check consumer offsets when the offset store is Kafka?

问题描述

从 0.8.1.1 版本开始，Kafka 提供了在 Kafka 中存储偏移量的规定，而不是 Zookeeper(参见 this).我无法弄清楚如何检查消耗的偏移量的详细信息，因为当前的工具只为 Zookeeper 提供消费者偏移量计数检查.(我指的是 this)

From 0.8.1.1 release, Kafka provides the provision for storage of offsets in Kafka, instead of Zookeeper (see this). I'm not able to figure out how to check the details of offsets consumed, as the current tools only provide consumer offset count checks for zookeeper only.(I'm referring to this)

如果有任何工具可用于检查消费者抵消，请告诉我.

If there are any tools available to check consumer offset, please let me know.

推荐答案

我正在使用 kafka 0.8.2，偏移量存储在 kafka 中.这个工具对我很有用:

I'am using kafka 0.8.2 with offsets stored in kafka. This tools works good for me:

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker 
        --topic your-topic 
        --group your-consumer-group
        --zookeeper localhost:2181

您可以获得所需的所有信息:主题大小、消费者滞后、所有者.

You get all informations you need: topic size, consumer lag, owner.

这篇关于当偏移存储是Kafka时如何检查消费者偏移?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！