Greetings,

I’m attempting to use the New Consumer in my project (0.9.0.1), and it
appears to be working nicely. The issue that I am seeing is that the
group.id is not showing up within:

kafka-consumer-groups.sh —bootstrap-server
kafka0.local:9092,kafka1.local:9092 —new-consumer —list

The command loads up, but the consumer that is running is not
displayed. The consumer is clearly processing a massive amount of
messages. I have included the properties used at the end of my
message.

Thanks,
Ryan

Properties props = new Properties();
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokerSeeds);
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
props.put(ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG, 6 * 1024 * 1024);
props.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, 30 * 1000);
props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 15 * 1000);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
"org.apache.kafka.common.serialization.StringDeserializer");
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
"org.apache.kafka.common.serialization.ByteArrayDeserializer");
consumer = new KafkaConsumer<String, byte[]>(props);

Reply via email to