我们在测试和生产中得到了这个。它是连续的,我们不知道这些错误如何每隔几秒钟就会出现一次,至少我们在测试中似乎没有来自另一个系统的反馈。
我们的消息非常小,最多只有几百字节。
这是 1.2 GB。我尝试将:socket.request.max.bytes 设置为 1195725856,但随后内存不足,即使堆大小约为 2.5 GB 并且 OpenShift 容器设置为最大 32GB。
非常欢迎任何帮助!
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104857600)
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:235)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:196)
at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:545)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:483)
at org.apache.kafka.common.network.Selector.poll(Selector.java:412)
at kafka.network.Processor.poll(SocketServer.scala:551)
at kafka.network.Processor.run(SocketServer.scala:468)
at java.lang.Thread.run(Thread.java:748)
Run Code Online (Sandbox Code Playgroud) apache-kafka ×1