I think what you are asking for is the "lag" on a topic for a specific consumer. This is basically how far behind you are falling behind the producer for a topic that is being written to the cluster.
something like this should help you figure that out. [path of kafka]/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper [zookeeperhost:2181] --topic [topicnamehere] --group [groupIDhere] On Thu, Dec 3, 2015 at 10:48 PM, Gaurav Agarwal <[email protected]> wrote: > Hello > How can I find in Kafka API in 0.8.1.1 count of uncommitted offsets > (unread message)from a particular topic .with the respective consumer group > I'd > I am looking after adminutils ,topic comand , and offsetrequest any > specific class of Kafka API which I can use to find am these things. >
