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日志的原因,我都试了也还是出现这个错误,但这个错误不影响我生产消费。要是哪位大神指导原因,请多指教。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐