From 294dcb0f59e3f9887db08ffb8ecae93466967e5c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?=
<514737+acogoluegnes@users.noreply.github.com>
Date: Thu, 6 Aug 2026 10:44:40 +0200
Subject: [PATCH] fix(network): bump default frame max to 20 MiB
From 1 MiB. To align with the new broker default (RabbitMQ 4.3.5).
References https://github.com/rabbitmq/rabbitmq-server/pull/17126
---
src/main/java/com/rabbitmq/stream/EnvironmentBuilder.java | 2 +-
src/main/java/com/rabbitmq/stream/impl/Client.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/rabbitmq/stream/EnvironmentBuilder.java b/src/main/java/com/rabbitmq/stream/EnvironmentBuilder.java
index c2be10d11e..811129d2a0 100644
--- a/src/main/java/com/rabbitmq/stream/EnvironmentBuilder.java
+++ b/src/main/java/com/rabbitmq/stream/EnvironmentBuilder.java
@@ -201,7 +201,7 @@ public interface EnvironmentBuilder {
/**
* The maximum frame size to request.
*
- * Default is 1048576.
+ *
Default is 20971520 (20 MiB).
*
* @param requestedMaxFrameSize
* @return this builder instance
diff --git a/src/main/java/com/rabbitmq/stream/impl/Client.java b/src/main/java/com/rabbitmq/stream/impl/Client.java
index 1ef86d6a7e..419d00e9bb 100644
--- a/src/main/java/com/rabbitmq/stream/impl/Client.java
+++ b/src/main/java/com/rabbitmq/stream/impl/Client.java
@@ -169,7 +169,7 @@ public class Client implements AutoCloseable {
public static final int DEFAULT_PORT = 5552;
public static final int DEFAULT_TLS_PORT = 5551;
static final int MAX_REFERENCE_SIZE = 256;
- static final int DEFAULT_MAX_FRAME_SIZE = 1048576;
+ static final int DEFAULT_MAX_FRAME_SIZE = 20971520; // 20 MiB
// used before the max frame size is negotiated with the server (tune/open exchange), so the
// client is never exposed to an unbounded or overly large frame from an unauthenticated peer
static final int DEFAULT_MAX_FRAME_SIZE_BEFORE_AUTHENTICATION = 8192;