у нас есть кластер hadoop с 3 кафками машин и 3 zookeeper серверами
версия hadoop - 2.6.4 (HORTONWORKS)
под логами zookeeper (/ var / log / zookper)
мы видели миллионы предупреждений типа:
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
реальная проблема о машинах кафки
- мы столкнулись с проблемой, что лидеры не сбалансированы, а разделы Кафки, которые в итоге получаются с лидером -1