2015-12-09 149 views
3

我最近設置了一個測試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能夠追蹤其偏移?

回答

11

好的,我想通了。我正在使用新的消費者/生產者API。這意味着我需要使用—new-consumer標誌。例如:

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

您正在使用哪個版本的kafka?我正在使用kafka_2.9.2-0.8.2.1,但我在bin目錄中找不到任何帶有名稱爲kafka-consumer-groups的shell腳本或bat腳本。 –

+0

我正在使用0.9.0。 – Ztyx

+0

沒有一個人正在使用0.10.0.0,不知道如何列出/刪除消費羣體 – d1xlord