1
我是Apache kafka的初學者。我在啓動服務器和zookeeper之間感到困惑。那麼請解釋kafka中的引導服務器是什麼以及它與zookeeper有什麼不同?從引導服務器或zookeeper使用消息意味着什麼。從引導服務器和zookeeper消耗消息有什麼區別?
我是Apache kafka的初學者。我在啓動服務器和zookeeper之間感到困惑。那麼請解釋kafka中的引導服務器是什麼以及它與zookeeper有什麼不同?從引導服務器或zookeeper使用消息意味着什麼。從引導服務器和zookeeper消耗消息有什麼區別?
你很困惑,因爲卡夫卡有兩位新老客戶。
您應該使用新的,這意味着您只需要配置引導服務器(您正在使用的卡夫卡經紀人的網址)並且不需要定義zookeeper連接網址。
如果您使用舊用戶,它需要Zookeeper保持其狀態(從每個分區讀取最後一條消息) - 因此您給它一個zookeeper URL(因爲它需要zookeeper),它使用Zookeeper找到卡夫卡經紀人。
那麼,如何在新消費者中獲得卡夫卡狀態,就像特定的經紀人有多少個主題和分區一樣,每個消費者羣體的每個主題的偏移量? –
有通常的命令行toold-kafka-topics,kafka-consumer-groups。 –