Wednesday, December 2, 2015 2:33 PM
Subject: Re: Kafka 0.8.2.1 - how to read from __consumer_offsets topic?
Hey Marina,
My mistake, I see you're using 0.8.2.1. Are you also providing the
formatter argument when using console-consumer.sh? Perhaps something like
this:
bin/kafka-console-consumer.sh --
; thanks!!
> Marina
>
>
>
> - Original Message -
> From: Jason Gustafson <ja...@confluent.io>
> To: users@kafka.apache.org
> Sent: Wednesday, December 2, 2015 2:33 PM
> Subject: Re: Kafka 0.8.2.1 - how to read from __consumer_offsets topic?
>
> Hey Marina,
>
>
-
From: Guozhang Wang <wangg...@gmail.com>
To: "users@kafka.apache.org" <users@kafka.apache.org>; Marina <ppi...@yahoo.com>
Sent: Thursday, December 3, 2015 12:05 PM
Subject: Re: Kafka 0.8.2.1 - how to read from __consumer_offsets topic?
Marina,
To check if the to
ers@kafka.apache.org>; Marina <
> ppi...@yahoo.com>
> Sent: Thursday, December 3, 2015 12:05 PM
> Subject: Re: Kafka 0.8.2.1 - how to read from __consumer_offsets topic?
>
> Marina,
>
> To check if the topic does exist in Kafka (i.e. offsets are stored in Kafka
&g
check?
> >
> > thanks!
> > Marina
> >
> >
> >
> > - Original Message -
> > From: Guozhang Wang <wangg...@gmail.com>
> > To: "users@kafka.apache.org" <users@kafka.apache.org>; Marina <
> > ppi...@yahoo.com>
&g
> >
> > anything else you think I could check?
> >
> > thanks!
> > Marina
> >
> >
> >
> > - Original Message -----
> > From: Guozhang Wang <wangg...@gmail.com>
> > To: "users@kafka.apache.org" <users@kafka.apache.o
I have this same problem . Can someone help ?
--Dhyan
On Wed, Nov 25, 2015 at 3:31 PM, Marina wrote:
> Hello,
>
> I'm trying to find out which offsets my current High-Level consumers are
> working off. I use Kafka 0.8.2.1, with **no** "offset.storage" set in the
>
Looks like you need to use a different MessageFormatter class, since it was
renamed in 0.9. Instead use something like
"kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter".
-Jason
On Wed, Dec 2, 2015 at 10:57 AM, Dhyan Muralidharan <
d.muralidha...@yottaa.com> wrote:
> I have this
Hello,
I'm trying to find out which offsets my current High-Level consumers are
working off. I use Kafka 0.8.2.1, with **no** "offset.storage" set in the
server.properties of Kafka - which, I think, means that offsets are stored in
Kafka. (I also verified that no offsets are stored in