diff --git a/reactivesocket-aeron-core/src/main/java/io/reactivesocket/aeron/internal/AeronUtil.java b/reactivesocket-aeron-core/src/main/java/io/reactivesocket/aeron/internal/AeronUtil.java
index <HASH>..<HASH> 100644
--- a/reactivesocket-aeron-core/src/main/java/io/reactivesocket/aeron/internal/AeronUtil.java
+++ b/reactivesocket-aeron-core/src/main/java/io/reactivesocket/aeron/internal/AeronUtil.java
@@ -142,7 +142,7 @@ public class AeronUtil implements Loggable {
         OneToOneConcurrentArrayQueue<MutableDirectBuffer> queue = unsafeBuffers.get();
         MutableDirectBuffer buffer = queue.poll();
 
-        if (buffer != null && buffer.capacity() < length) {
+        if (buffer != null && buffer.capacity() >= length) {
             return buffer;
         } else {
             byte[] bytes = new byte[length];
switching check to prevent out of bounds exception