From c43bcad3664592045a2f3408390e9eb4d6016dd6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?=
 <514737+acogoluegnes@users.noreply.github.com>
Date: Wed, 16 Jul 2025 15:30:36 +0200
Subject: [PATCH] Use adaptative byte buffer allocator

---
 src/main/java/com/rabbitmq/stream/impl/Utils.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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;
   }
 
   /*