id 1 连接中断的根本原因，我的 id = 3，错误 =答案

【问题标题】：Root cause for Connection broken for id 1, my id = 3, error =id 1 连接中断的根本原因，我的 id = 3，错误 =
【发布时间】：2021-07-07 05:11:45
【问题描述】：

我正在使用 Confluent 4 安装 kafka 和 zookeeper。

在我们的 Kafka 集群环境中（3 个代理和 3 个 Zookeeper 节点在 3 个 AWS 实例上运行）我们看到以下一组警告，反复记录在代理的 server.log 文件中。

我们还没有观察到任何功能问题，但我们无法找到根本原因，并且将来可能会影响客户端或其他代理节点。我们还不确定这一点。以下是一组警告

[2018-04-03 12:00:40,707] WARN Interrupted while waiting for message on queue (org.apache.zookeeper.server.quorum.QuorumCnxManager)
java.lang.InterruptedException
 at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
 at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2088)
 at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
 at org.apache.zookeeper.server.quorum.QuorumCnxManager.pollSendQueue(QuorumCnxManager.java:1097)
 at org.apache.zookeeper.server.quorum.QuorumCnxManager.access$700(QuorumCnxManager.java:74)
 at org.apache.zookeeper.server.quorum.QuorumCnxManager$SendWorker.run(QuorumCnxManager.java:932)
[2018-04-03 12:00:40,707] WARN Connection broken for id 1, my id = 3, error =  (org.apache.zookeeper.server.quorum.QuorumCnxManager)
java.net.SocketException: Socket closed
 at java.net.SocketInputStream.socketRead0(Native Method)
 at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
 at java.net.SocketInputStream.read(SocketInputStream.java:171)
 at java.net.SocketInputStream.read(SocketInputStream.java:141)
 at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
 at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
 at java.io.DataInputStream.readInt(DataInputStream.java:387)
 at org.apache.zookeeper.server.quorum.QuorumCnxManager$RecvWorker.run(QuorumCnxManager.java:1013)
[2018-04-03 12:00:40,708] WARN Interrupting SendWorker (org.apache.zookeeper.server.quorum.QuorumCnxManager)
[2018-04-03 12:00:40,707] WARN Send worker leaving thread (org.apache.zookeeper.server.quorum.QuorumCnxManager)

这组警告会在所有 3 个 kafka 节点中重复并得到观察。

如果有人知道为什么会生成此警告，请告诉我。

提前致谢。

【问题讨论】：

这好像是zk日志，检查id为1的zk节点。

标签： apache-kafka apache-zookeeper confluent-platform

【解决方案1】：

这听起来像是新版本 Zk 的一个已知问题，请查看此 JIRA https://issues.apache.org/jira/browse/ZOOKEEPER-2938

【讨论】：

【解决方案2】：

在我的例子中，我正在更换一个 ZK 节点，而旧的节点仍在运行，这是我没有意识到的。所以我创建了 2 个具有相同“myid”的节点。

【讨论】：