Java consumer group missing?

Question

I recently set up a test Kafka cluster. I am running a consumer group listening on items and things seem to work. The name of consumer group is default. What surprises me is that listing consumer groups gives me an empty list:

$ ./bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list
$

Also, explicitly querying the offsets doesn't yield anything:

$ ./bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group default
No topic available for consumer group provided
GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER

Do I need to manually create a consumer group using kafka-consumer-groups.sh —new-consumer to be able to track its offsets?

Answer 1

Okay, I figured it out. I am using the new consumer/producer API. This means I need to use the —new-consumer flag. Example:

$ ./bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
default
$