監測卡夫卡消費滯後

Question

我想寫一個shell腳本使用

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 group test 

在 http://kafka.apache.org/documentation.html#basic_ops_consumer_lag提到

監測消費滯後於我的羣集。 我有3個服務器被用作動物園管理員的嗎？我是否需要提供所有3的地址作爲參數以獲取運行的消費者組的報告。

Answer 1

一般來說，沒有。動物園管理員將彼此進行溝通，然後以與所有服務器一致的答案作出迴應。這是Zookeeper運行的假設之一，除非它們遇到故障。

如果你查詢一個，如果它有足夠的信息，它會迴應，如果沒有，它會問其他動物園管理員的信息，然後回覆。

Answer 2

那麼，一般來說，你應該這樣做，因爲如果你在zkconnect中指定了少數服務器並且少數服務器不可用，即使動物園管理員合奏組啓動並運行，你的調用也將失敗。