Java 消费群不见了？

Question

我最近设置了一个测试 Kafka 集群。我是运行一个消费者群体，他们正在聆听商品，而且似乎一切正常。消费者组的名称是default。令我惊讶的是列出消费者群体给我一个空列表：

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

此外，显式查询偏移量不会产生任何结果：

$ ./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

我是否需要使用 kafka-consumer-groups.sh —new-consumer 手动创建消费者组才能跟踪其偏移量？

Answer 1

好的，我明白了。我正在使用新的 consumer/producer API。这意味着我需要使用 —new-consumer 标志。示例：

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

Java 消费群不见了？

Java consumer group missing?

apache-kafka

kafka-producer-api