我想编写一个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个服务器被用作zookeeper的do，我需要向所有3个服务器提供地址作为参数，以便为正在运行的使用者组获取报告。
我想编写一个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个服务器被用作zookeeper的do，我需要向所有3个服务器提供地址作为参数，以便为正在运行的使用者组获取报告。
2条答案
按热度按时间au9on6nz1#
一般来说，不会。Zookeeper会相互交流，然后给出与所有服务器一致的答案。这是zookeeper运行的假设之一，除非他们正在经历失败。
如果你查询一个，如果它有足够的信息，它会回答，如果没有，它会要求其他Zookeeper提供信息，然后回答。
deikduxw2#
一般来说，您应该这样做，因为如果您在zkconnect中指定少数服务器，并且该少数服务器不可用，那么即使zookeeper集合已启动并正在运行，您的调用也将失败。