From 29f1f6370ceb4266840085151fb6dda0fd650f1b Mon Sep 17 00:00:00 2001
From: Philippe Labat <philippe.labat@me.com>
Date: Mon, 9 Sep 2024 14:55:43 -0400
Subject: [PATCH] DBZ-7909: Making sure RequestedFrameMax get sent to
 StreamClient

This fixes an issue I was having where I was setting the frame_max variable on the connection configuration but it was not propagating to the StreamClient. This patch fixes this issue.
---
 .../server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/debezium-server-rabbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java b/debezium-server-rabbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java
index e4509005..ce24e9f4 100644
--- a/debezium-server-rabbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java
+++ b/debezium-server-rabbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java
@@ -111,6 +111,7 @@ void connect() {
                     .username(factory.getUsername())
                     .password(factory.getPassword())
                     .virtualHost(factory.getVirtualHost())
+                    .requestedMaxFrameSize(factory.getRequestedFrameMax())
                     .build();
         }
         catch (StreamException | IllegalArgumentException e) {