Hi Tao,
Sorry for the delay. Thanks for pointing out that property. That was the
fix.
On Mon, May 9, 2016 at 6:00 PM, tao xiao wrote:
> You need to enable internal topic in the consumer.properties
>
> exclude.internal.topics=false
>
> On Mon, 9 May 2016 at 12:42 Cliff Rhyne wrote:
>
> > Than
You need to enable internal topic in the consumer.properties
exclude.internal.topics=false
On Mon, 9 May 2016 at 12:42 Cliff Rhyne wrote:
> Thanks Todd and Tao. I've tried those tricks but no luck.
>
> Just to add more info, this is the __consumer_offsets specific config that
> is shown by the
Thanks Todd and Tao. I've tried those tricks but no luck.
Just to add more info, this is the __consumer_offsets specific config that
is shown by the topic describe command:
Configs:segment.bytes=104857600,cleanup.policy=compact,compression.type=uncompressed
On Mon, May 9, 2016 at 1:16 PM, tao x
You can try this
bin/kafka-console-consumer.sh --consumer.config
config/consumer.properties --from-beginning
--topic __consumer_offsets --zookeeper localhost:2181 —formatter
"kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter"
On Mon, 9 May 2016 at 09:40 Todd Palino wrote:
> The Gr
The GroupMetadataManager one should be working for you with 0.9. I don’t
have a 0.9 KCC set up at the moment, so I’m using an 0.8 version where it’s
different (it’s the other class for me). The only thing I can offer now is
did you put quotes around the arg to --formatter so you don’t get weird
she
Thanks, Todd. It's still not working unfortunately.
This results in nothing getting printed to the console and requires kill -9
in another window to stop (ctrl-c doesn't work):
/kafka-console-consumer.sh --bootstrap-server localhost:9092 --zookeeper
--topic __consumer_offsets --formatter
kafka.
It looks like you’re just missing the proper message formatter. Of course,
that largely depends on your version of the broker. Try:
./kafka-console-consumer.sh --broker-list localhost:9092 --topic
__consumer_offsets
--formatter kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter
If f
