apache-kafka - 有什么方法可以检查 kafka 是否已从 kafka-net 启动并运行

Question

我正在使用 kafka-net 客户端向 kafka 发送消息。我只是想知道是否有任何方法可以检查 kafka 服务器是否已启动并可以接收消息。我关闭了 kafka，但是已经成功创建了生产者并且 SendMessageAsync 只是卡住了很长时间。我试图通过超时，但它没有改变任何东西。我使用 kafka-net 0.9
当 kafka 服务器启动并运行时它工作得很好

Answer 1

Broker的id在zookeeper(/brokers/ids/[brokerId])注册为临时节点，允许其他broker和consumer检测故障。它死了)。

zookeeper ephemeral node exists as long as the broker's session is active.

您可以通过 ZkUtils.getSortedBrokerList(zkClient) 检查代理是否已启动，它返回 /brokers/ids/[brokerId] 下的所有事件代理 ID。

import org.I0Itec.zkclient.ZkClient;

ZkClient zkClient = new ZkClient(properties.getProperty("zkQuorum"), zkSessionTimeout, zkConnectionTimeout,ZKStringSerializer$.MODULE$);
ZkUtils.getSortedBrokerList(zkClient);

引用
Kafka data structures in Zookeeper