contoller.logs 中的 Kafka 连接错误

Question

我正在使用单节点 Kafka（v 0.10.2）和单节点zookeeper（v 3.4.8），我的controller.log 文件充满了这个异常

java.io.IOException: Connection to 1 was disconnected before the response was read
    at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$3(NetworkClientBlockingOps.scala:114)
    at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$3$adapted(NetworkClientBlockingOps.scala:112)
    at scala.Option.foreach(Option.scala:257)
    at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$1(NetworkClientBlockingOps.scala:112)
    at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:136)
    at kafka.utils.NetworkClientBlockingOps$.pollContinuously$extension(NetworkClientBlockingOps.scala:142)
    at kafka.utils.NetworkClientBlockingOps$.blockingSendAndReceive$extension(NetworkClientBlockingOps.scala:108)
    at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:192)
    at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:184)
    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

我用谷歌搜索了这个异常，但无法找到这个异常的根本原因。有人可以告诉我为什么会发生这个错误以及如何防止它吗？

Answer 1

我在多节点集群场景中也遇到了同样的问题。这是因为kafka-node和zookeeper之间的连接关闭。我建议重新启动zookeeper服务器，然后重新启动kafka节点以重新建立连接，因此代理应该处理发布/订阅消息转换。希望它能让你从此摆脱困境。