kafka1.1.1集群运行出现org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = -720899)?

想喝好几罐八宝粥的男孩 发表于: 2020-06-17   最后更新时间: 2020-06-18 09:41:44   3,864 游览

kafka集群正常运行下,突然有一个节点宕机,请教大神解答一下。@半兽人
kafka版本1.1.1,环境正式生产环境,主要是采集相关数据发送到kakfa中。相关的参数均为默认值:

socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600

报错信息为:

org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = -720899)

由于配置了自动重启kafka脚本,过一段时间后,kafka机器重新恢复正常,查找源码发现,screenshot
screenshot

发表于 2020-06-17

size表示读取的字符或字节数,为 None 或负数时读取到了EOF,是结尾处

那读取到了结尾处,不就应该停止了或者等待下次在拉取吗?为啥还自动报错为负值呢。,

这只是个警告错误呀,是会继续读取的。
接收信息负数,只是其他触发的表现,宕机要看该节点的完整日志。

我把我的机器当时的报错日志截图发给你看一下,大佬,但是这个节点再出现这个问题后直接挂掉了,回复中不能截图,已经在问答中截图,麻烦大佬再帮我看看吧,这是在正式环境中挂掉一个节点会对集群产生重大影响,谢谢了

看到你的补充内容了,只是个警告。找找ERROR级别的。

error级别的没有哈,谢谢大佬了,好在集群配置了自动拉起kafka服务,在检测到kafka节点挂掉后会自动拉起来。继续向大佬学习。

你的答案

查看kafka相关的其他问题或提一个您自己的问题