在一次项目上线的时候出现了org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1896679949 larger than 104857600)
,我是生产者发送数据方,这个报错是对方的Kafka日志size
这个数大到不合理的存在;
当时怀疑是我这边发送数据过大导致的,但是我看了我的代码,根本发不出这种超大的数据量,直到我在本地复现这个问题所在
相信图片已经很清楚了,当时是我们在确认对方的kafka
的端口是否通畅的时候我调用了telnet [ip] [port]
, 没想到吧,被一个shell
命令所绊倒了,当通过telnet
命令的时候会导致kfaka
和zookeeper
这种抛出size
过大问题;