zookeeper + 无法从客户端会话 ID 中读取额外数据 [英] zookeeper + Unable to read additional data from client session id
本文介绍了zookeeper + 无法从客户端会话 ID 中读取额外数据的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我们有具有 3 台 kafka 机器和 3 个 zookeeper 服务器的 hadoop 集群
we have hadoop cluster with 3 kafka machines and 3 zookeeper servers
hadoop 版本 - 2.6.4 (HORTONWORKS)
hadoop version - 2.6.4 ( HORTONWORKS )
在zookeeper日志(/var/log/zookper )下
under zookeeper logs ( /var/log/zookper )
我们看到了数百万条警告消息,例如:
we saw a millions WARN messages like:
2019-06-26 10:48:45,675 [myid:1] - WARN [NIOServerCxn.Factory 0.000.0.0/0.0.0.0:2181:NIOServerCnxn@357] - caught end of stream exception
EndOfStreamException: Unable to read additional data from client sessionid 0x16b8e15a80ca681, likely client has closed socket
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208)
at java.lang.Thread.run(Thread.java:745)
此消息的含义是什么:
caught end of stream exception EndOfStreamException
Unable to read additional data from client sessionid
真正的问题是关于 kafka 机器
the real problem is about the kafka machines
- 我们面临的问题是领导者不平衡,Kafka 主题分区最终得到领导者 -1
推荐答案
尝试让客户端重试.它解决了我的问题.不知何故,我将重试设置为零.
Try to have client retries. It solved my issue. Somehow I had retry set to zero.
例如:hbase.client.retries.number
这篇关于zookeeper + 无法从客户端会话 ID 中读取额外数据的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文