apache-kafka - controller.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-node重新建立连接，因此代理应该处理发布/订阅消息转换。
希望它能让你从这件事中得到提升。