监测卡夫卡消费滞后

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中指定了少数服务器并且少数服务器不可用，即使动物园管理员合奏组启动并运行，你的调用也将失败。