admin管理员组

文章数量:1641954

最近在 aliyun 服务器 部署kafka 遇到的问题

复现

   执行  bin/kafka-server-start.sh config/server.properties 

org.apache.kafkamonwork.InvalidReceiveException: Invalid receive (size = 97307 larger than xxx)
    at org.apache.kafkamonwork.NetworkReceive.readFromReadableChannel(NetworkReceive.java:132)
    at org.apache.kafkamonwork.NetworkReceive.readFrom(NetworkReceive.java:93)
    at org.apache.kafkamonwork.KafkaChannel.receive(KafkaChannel.java:231)
    at org.apache.kafkamonwork.KafkaChannel.read(KafkaChannel.java:192)
    at org.apache.kafkamonwork.Selector.attemptRead(Selector.java:528)
    at org.apache.kafkamonwork.Selector.pollSelectionKeys(Selector.java:469)
    at org.apache.kafkamonwork.Selector.poll(Selector.java:398)
    at kafkawork.Processor.poll(SocketServer.scala:535)
    at kafkawork.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)

 

本文标签： NetworknvalidReceiveExceptionKafkacommonInvalid

版权声明：本文标题：kafka.common.network.nvalidReceiveException: Invalid receive (size = xxx larger than xxx) 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://m.elefans.com/xitong/1729330722a1196359.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。