diff --git a/src/main/java/com/rabbitmq/stream/impl/Utils.java b/src/main/java/com/rabbitmq/stream/impl/Utils.java index 537ee7efbf..73d61716f0 100644 --- a/src/main/java/com/rabbitmq/stream/impl/Utils.java +++ b/src/main/java/com/rabbitmq/stream/impl/Utils.java @@ -20,7 +20,6 @@ import com.rabbitmq.stream.*; import com.rabbitmq.stream.impl.Client.ClientParameters; import io.netty.buffer.ByteBufAllocator; -import io.netty.buffer.PooledByteBufAllocator; import io.netty.channel.ConnectTimeoutException; import io.netty.channel.EventLoopGroup; import io.netty.channel.MultiThreadIoEventLoopGroup; @@ -434,7 +433,8 @@ static EventLoopGroup eventLoopGroup() { } static ByteBufAllocator byteBufAllocator() { - return PooledByteBufAllocator.DEFAULT; + return ByteBufAllocator.DEFAULT; + // return PooledByteBufAllocator.DEFAULT; } /*