监控 Kafka 消费者滞后

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 之间将进行通信，然后以与所有服务器一致的答案进行响应。这是 Zookeeper 运行的假设之一，除非他们遇到故障。

如果你查询一个，如果它有足够的信息，它会回应，如果没有，它会向其他动物园管理员询问信息，然后回复。