在一次项目上线的时候出现了org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1896679949 larger than 104857600),我是生产者发送数据方,这个报错是对方的Kafka日志size这个数大到不合理的存在;

当时怀疑是我这边发送数据过大导致的,但是我看了我的代码,根本发不出这种超大的数据量,直到我在本地复现这个问题所在

kafka telnet

相信图片已经很清楚了,当时是我们在确认对方的kafka的端口是否通畅的时候我调用了telnet [ip] [port], 没想到吧,被一个shell命令所绊倒了,当通过telnet命令的时候会导致kfakazookeeper这种抛出size过大问题;