Kafka-python 连接丢失

Question

我想知道如何验证与 kafka 的连接：让我更好地解释一下：

我有一个 KafkaConsumer 正在等待消费消息，让我们假设 kafka 连接同时断开。当我尝试在我的消费者上使用我的迭代来消费消息并且连接丢失时，它将继续出现异常。
有什么方法可以检查连接吗？ 我使用的是 kafka-python 1.3.3 版。

这是一段代码：

consumer = KafkaConsumer(....)
for msg in consumer:
    DO....

这是我在迭代期间的执行：

getaddrinfo failed for kafka:9092, exception was [Errno -2] Name or service not known

谢谢大家

Answer 1

如果您使用的是 Linux 操作系统，那么您可以从您的 Linux 终端检查 Kafka 连接是否正常。可以使用telnet命令，定义kafka-ip和kafka-port

telnet 127.0.0.1 9092