在使用SpringBoot连接服务器的kafka时候,一启动SpringBoot,kafka服务就报如下错误
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104857600)
但问题是我启动的时候并没有发送那么大数据的请求,为啥会报这个错呢,试过了重启kafka服务,还是有这个问题,而且是连续报三次,具体报错如下
上图是SpringBoot启动时,打印的日志。
这里有人遇到了,调整方案也可参考:https://www.orchome.com/1347
之前的消息积压
另外,这些异常,跟你的使用规模,消息数,消息大小,体量都有关系。还跟你之前改了某些参数提升吞吐的,但max没调整。
参考:
应该不是消息积压吧,我是刚开始学kafka,新建的一个topic,都没有发送过消息,springboot一启动就会报这个错,参数倒是把log.segment.bytes的值调小了
兄弟,没有消息,怎么会报接收数量大于呢?你连错kafka集群了吧
先用命令行测试你的集群吧:kafka命令大全
你的答案