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

好的,我明白了.我正在使用新的消费者/生产者API.这意味着我需要使用—new-consumer标志.例:

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