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 <tpal...@gmail.com> wrote: > 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 > shell interference? > > -Todd > > > On Mon, May 9, 2016 at 8:18 AM, Cliff Rhyne <crh...@signal.co> wrote: > > > 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 > > <zkhost> --topic __consumer_offsets --formatter > > kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter > > > > This results in a stack trace because it can't find the class: > > > > ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --zookeeper > > <zkhost> --topic __consumer_offsets --formatter > > kafka.server.OffsetManager\$OffsetsMessageFormatter > > > > Exception in thread "main" java.lang.ClassNotFoundException: > > kafka.server.OffsetManager$OffsetsMessageFormatter > > > > > > I'm on 0.9.0.1. "broker-list" is invalid and zookeeper is required > > regardless of the bootstrap-server parameter. > > > > > > Thanks, > > > > Cliff > > > > On Sun, May 8, 2016 at 7:35 PM, Todd Palino <tpal...@gmail.com> wrote: > > > > > 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 for some reason that doesn’t work, you can try > > > "kafka.server.OffsetManager\$OffsetsMessageFormatter” instead. > > > > > > -Todd > > > > > > > > > > > > > > > On Sun, May 8, 2016 at 1:26 PM, Cliff Rhyne <crh...@signal.co> wrote: > > > > > > > I'm having difficulty reading the consumer offsets topic from the > > command > > > > line. I try the following but it doesn't seem to work (along with a > > few > > > > related variants including specifying the zookeeper hosts): > > > > > > > > ./kafka-console-consumer.sh --broker-list localhost:9092 --topic > > > > __consumer_offsets > > > > > > > > Is there a special way to read the consumer offsets topic? > > > > > > > > Thanks, > > > > Cliff > > > > > > > > -- > > > > Cliff Rhyne > > > > Software Engineering Manager > > > > e: crh...@signal.co > > > > signal.co > > > > ________________________ > > > > > > > > Cut Through the Noise > > > > > > > > This e-mail and any files transmitted with it are for the sole use of > > the > > > > intended recipient(s) and may contain confidential and privileged > > > > information. Any unauthorized use of this email is strictly > prohibited. > > > > ©2016 Signal. All rights reserved. > > > > > > > > > > > > > > > > -- > > > *—-* > > > *Todd Palino* > > > Staff Site Reliability Engineer > > > Data Infrastructure Streaming > > > > > > > > > > > > linkedin.com/in/toddpalino > > > > > > > > > > > -- > > Cliff Rhyne > > Software Engineering Manager > > e: crh...@signal.co > > signal.co > > ________________________ > > > > Cut Through the Noise > > > > This e-mail and any files transmitted with it are for the sole use of the > > intended recipient(s) and may contain confidential and privileged > > information. Any unauthorized use of this email is strictly prohibited. > > ©2016 Signal. All rights reserved. > > > > > > -- > *—-* > *Todd Palino* > Staff Site Reliability Engineer > Data Infrastructure Streaming > > > > linkedin.com/in/toddpalino >
