EndOfStreamException: Unable to read additional data from client sessionid 0x16b0bd525660003
EndOfStreamException: Unable to read additional data from client sessionid 0x16b0bd525660003, likely client has closed socket简单说明一下这个错误是我在测试kafka时遇到的问题开始按照该网址说明安装kafka,访问Kafka官方下载页面,下载稳定版本2.11-0.10...
·
EndOfStreamException: Unable to read additional data from client sessionid 0x16b0bd525660003, likely client has closed socket
简单说明一下这个错误是我在测试kafka时遇到的问题
开始按照该网址说明安装kafka,访问Kafka官方下载页面,下载稳定版本2.11-0.10.1.0的kafka.此安装包内已经附带zookeeper,所以不需要额外安装zookeeper,安装之后,我没有配置什么直接启动zookeeper.
bin/zookeeper-server-start.sh config/zookeeper.properties
就出现了该问题。解决办法如下
进入kafka/conf/
,修改server.properties:
将zookeeper.connection.timeout.ms=6000这个6000调大,调成30000
再启动zookeeper时问题没了。原因是配置的超时时间太短,zookeeper没有读完Consumer的数据,连接就被断开了。神奇的是,我后来又给改成6000,问题也不再出现了,哈哈哈哈,布吉岛问什么。
之后我又启动了kafka
bin/kafka-server-start.sh config/server.properties
出现了这个错误。
网上查阅说是不正确关闭zookeeper和server的原因,还有说是没有删除/tmp下的zookeeper日志和kafka日志的原因,我都试了也还是出现这个错误,但这个错误不影响我生产消费。要是哪位大神指导原因,请多指教。
更多推荐
已为社区贡献1条内容
所有评论(0)