Мы постоянно видим это исключение в наших журналах и сбой нашего сервера.Это отдельная JVM.
"kafka-producer-network-thread | producer-1" daemon prio=5 tid=15 RUNNABLE
at java.lang.OutOfMemoryError.<init>(OutOfMemoryError.java:48)
at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57)
at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:93)
local variable: org.apache.kafka.common.network.PlaintextTransportLayer#1
local variable: org.apache.kafka.common.network.NetworkReceive#1
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71)
at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:169)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:150)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:355)
local variable: java.util.HashMap$KeyIterator#10
local variable: org.apache.kafka.common.network.KafkaChannel#2
local variable: sun.nio.ch.SelectionKeyImpl#2
at org.apache.kafka.common.network.Selector.poll(Selector.java:303)
local variable: org.apache.kafka.common.network.Selector#7
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:349)
local variable: org.apache.kafka.clients.NetworkClient#4
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:225)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:126)
local variable: org.apache.kafka.clients.producer.internals.Sender#1
at java.lang.Thread.run(Thread.java:745)