Re: Need help determining consumer group offsets

[Greg Lloyd]

Hi Alex,

Nice to see you on this list. I actually figured out my problem was quite
silly. I was prefixing the consumer group name with the cassandra keyspace
and was looking for the wrong group name.


On Thu, Mar 23, 2017 at 7:44 AM, Alexandru Ionita <
alexandru.ion...@gmail.com> wrote:

> Hi Greg!!
>
> Are you using offset auto commit or do you commit manually?
>
> 2017-03-22 22:21 GMT+01:00 Greg Lloyd :
>
> > I have a 0.8.2.2 cluster which has been configured
> > with offsets.storage=kafka. We are experiencing some issues after a few
> > nodes went down and wrong nodes were brought up in their place,
> fortunately
> > not production. I am trying to determine what the current offsets are
> for a
> > consumer group and can't seem to get any offsets from either
> > zookeeper(expected) or the __consumer_offsets topic.
> >
> > How can I fetch the group offsets if not from that topic?
> >
>

Re: Need help determining consumer group offsets

[Alexandru Ionita]

Hi Greg!!

Are you using offset auto commit or do you commit manually?

2017-03-22 22:21 GMT+01:00 Greg Lloyd :

> I have a 0.8.2.2 cluster which has been configured
> with offsets.storage=kafka. We are experiencing some issues after a few
> nodes went down and wrong nodes were brought up in their place, fortunately
> not production. I am trying to determine what the current offsets are for a
> consumer group and can't seem to get any offsets from either
> zookeeper(expected) or the __consumer_offsets topic.
>
> How can I fetch the group offsets if not from that topic?
>

Need help determining consumer group offsets

[Greg Lloyd]

I have a 0.8.2.2 cluster which has been configured
with offsets.storage=kafka. We are experiencing some issues after a few
nodes went down and wrong nodes were brought up in their place, fortunately
not production. I am trying to determine what the current offsets are for a
consumer group and can't seem to get any offsets from either
zookeeper(expected) or the __consumer_offsets topic.

How can I fetch the group offsets if not from that topic?