You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Gaurav Agarwal <ga...@gmail.com> on 2015/12/04 04:48:51 UTC
Kafka uncomitted offset
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.
Re: Kafka uncomitted offset
Posted by Gaurav Agarwal <ga...@gmail.com>.
Tx
On Dec 4, 2015 9:11 PM, "scott macfawn" <sc...@gmail.com> 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 <ga...@gmail.com>
> 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.
> >
>
Re: Kafka uncomitted offset
Posted by scott macfawn <sc...@gmail.com>.
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 <ga...@gmail.com>
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.
>