Tx On Dec 4, 2015 9:11 PM, "scott macfawn" <[email protected]> wrote:
> 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. > > >
