diff --git a/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala b/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala index d36944a..4b1ab56 100644 --- a/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala +++ b/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala @@ -80,8 +80,10 @@ private[kafka] class BoundedByteBufferReceive(val maxSize: Int) extends Receive buffer = ByteBuffer.allocate(size) } catch { - case e: OutOfMemoryError => - throw new RuntimeException("OOME with size " + size, e) + case e: OutOfMemoryError => { + logger.error("OOME with size " + size, e) + throw e + } case e2 => throw e2 }