最近在 aliyun 服务器 部署kafka 遇到的问题
复现
执行 bin/kafka-server-start.sh config/server.properties
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 97307 larger than xxx)
at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:132)
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:93)
at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:231)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:192)
at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:528)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:469)
at org.apache.kafka.common.network.Selector.poll(Selector.java:398)
at kafka.network.Processor.poll(SocketServer.scala:535)
at kafka.network.Processor.run(SocketServer.scala:452)
at java.lang.Thread.run(Thread.java:748)
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
查看原因 是 nvalid receive (size = 97307 larger than xxx)，
在加载 server.properties ,调整 socket.request.max.bytes
关于这个属性 kafka 有一个默认限制大小， 超过这个大小， 就会出现连接异常。
官方给的解释是 (通过限制请求的大小， 来防止OOM ？？)
The maximum size of a request that the socket server will accept (protection against OOM)
