我想知道如何验证与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谢谢大家
发布于 2018-07-12 14:58:40
如果你使用的是Linux操作系统,那么你可以从你的Linux终端检查Kafka连接,无论它是否工作。您可以使用telnet命令并定义kafka-ip和kafka-port
telnet 127.0.0.1 9092 https://stackoverflow.com/questions/48249093
复制相似问题