Yes, it is similar to console consumer. Just pass exclude.internal.topics=false config to KafkaConsumer configs.
On Wed, Feb 1, 2017 at 9:39 PM, Wang, Howard <[email protected]> wrote: > Hi, > > I have a use case where I need to programmatically consume the internal > office __consumer_offsets in Kafka 10 for data recovery. > > I am able to use the console consumer to consume the internal topic. But I > wonder if I can use KafkaConsumer class from my Java program to do the > same thing. And if yes, how? > > The console consumer which works for me looks like the following: > echo "exclude.internal.topics=false" > /tmp/consumer.config;~/tools/ > kafka_2.11-0.10.0.1/bin/kafka-console-consumer.sh --zookeeper zk-<my > server> --topic __consumer_offsets --consumer.config /tmp/consumer.config > --formatter "kafka.coordinator.GroupMetadataManager\$ > OffsetsMessageFormatter” > > > Thanks. > > Howard >
