我们在节点kaka客户端中遇到连接断开的问题。看来Zookeeper正在重置我们的连接。当我运行tcpdump时,在wireshark中查看时,我会看到以下内容:
源始终是我们的zookeeper服务器之一,目标是我们的kafka消费者。看来我们的客户在大多数情况下都能很好地处理这些问题。事实上,我一点也不相信这是我们失败的原因。但是,这看起来确实很奇怪。我希望在卡卡节点、Zookeeper和Kafka互动方面有更多经验的人能提供一些解释。
从日志中添加一些详细信息
所以,我在日志里看到了一些东西。首先,有一吨以下:
2016-03-11 20:26:32,357 [myid:2] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@868] - Client attempting to establish new session at /10.196.2.106:59300
2016-03-11 20:26:32,358 [myid:2] - WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@822] - Connection request from old client /10.196.2.106:59296; will be dropped if server is in r-o mode
还有一大堆这样的东西:
2016-03-12 03:40:49,041 [myid:1] - WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@357] - caught end of stream exception
EndOfStreamException: Unable to read additional data from client sessionid 0x1527b11827bfcfe, likely client has closed socket
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228)
at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208)
at java.lang.Thread.run(Thread.java:745)
2016-03-12 03:40:49,042 [myid:1] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1007] - Closed socket connection for client /10.196.2.106:33197 which had sessionid 0x1527b11827bfcfe
奇怪的是ips与secor服务器相关。所以,这可能没有关系。
除此之外,我没有看到任何真正与众不同的东西。
暂无答案!
目前还没有任何答案,快来回答吧!