【未解决】kafka异常 org.apache.kafka.common.network.InvalidReceiveException
问题:org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1903520116 larger than 104857600)分析:在进行socket连接的时候,kafka报错,提示接收的字节数大于设置的最大字节数,1000M了。可能是什么原因呢?测试java socket连接查找...
·
问题:org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1903520116 larger than 104857600)
分析:
在进行socket连接的时候,kafka报错,提示接收的字节数大于设置的最大字节数,1000M了。
可能是什么原因呢?
测试java socket连接
查找关于javasocket连接发送字节数的相关信息。
在测试过程中,原先我的java代码里有一行代码(原打算传入一个quit命令,关闭链接,不知道实际是否有用),去掉以后可以消除这个错误
out.write(“quit”.getBytes());
另外又发现了一个错误,同样是socket链接,会造成这个问题,待以后深入研究。
更多推荐
所有评论(0)