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
