admin管理员组文章数量:1641877
最近在 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://www.elefans.com/xitong/1729330722a1196359.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论