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
能夠追蹤其偏移?
您正在使用哪個版本的kafka?我正在使用kafka_2.9.2-0.8.2.1,但我在bin目錄中找不到任何帶有名稱爲kafka-consumer-groups的shell腳本或bat腳本。 –
我正在使用0.9.0。 – Ztyx
沒有一個人正在使用0.10.0.0,不知道如何列出/刪除消費羣體 – d1xlord