2016-09-01 45 views

回答

3

你很困惑,因爲卡夫卡有兩位新老客戶。

您應該使用新的,這意味着您只需要配置引導服務器(您正在使用的卡夫卡經紀人的網址)並且不需要定義zookeeper連接網址。

如果您使用舊用戶,它需要Zookeeper保持其狀態(從每個分區讀取最後一條消息) - 因此您給它一個zookeeper URL(因爲它需要zookeeper),它使用Zookeeper找到卡夫卡經紀人。

+0

那麼,如何在新消費者中獲得卡夫卡狀態,就像特定的經紀人有多少個主題和分區一樣,每個消費者羣體的每個主題的偏移量? –

+0

有通常的命令行toold-kafka-topics,kafka-consumer-groups。 –