id为1,my id=3的连接中断的根本原因,错误=

jutyujz0  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(1711)

我使用的Kafka和zookeeper安装合流4。
在我们的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节点中重复出现并被观察到。
如果有人知道为什么会产生这个警告,请告诉我。
提前谢谢。

jjjwad0x

jjjwad0x1#

这听起来像是zk新版本的一个已知问题,看看这个jirahttps://issues.apache.org/jira/browse/zookeeper-2938

相关问题