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