Java消费者群失踪？

我最近设置了一个测试Kafka集群。我正在运行一个消费者组织，倾听项目，事情似乎有效。消费群组的名称是default。令我惊讶的是，上市的消费群体给我一个空列表：Java消费者群失踪？

$ ./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能够追踪其偏移？

来源

2015-12-09 Ztyx

好的，我想通了。我正在使用新的消费者/生产者API。这意味着我需要使用—new-consumer标志。例如：

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

来源

2015-12-09 14:35:20 Ztyx

您正在使用哪个版本的kafka？我正在使用kafka_2.9.2-0.8.2.1，但我在bin目录中找不到任何带有名称为kafka-consumer-groups的shell脚本或bat脚本。 –

我正在使用0.9.0。 – Ztyx

没有一个人正在使用0.10.0.0，不知道如何列出/删除消费群体 – d1xlord

Java消费者群失踪？

回答

相关问题