From 8f810ec0194cecbe0fc7872e2a2ac14834372dd5 Mon Sep 17 00:00:00 2001
From: Nick Gerakines <12125+ngerakines@users.noreply.github.com>
Date: Thu, 7 Nov 2024 07:48:35 -0500
Subject: [PATCH] chore: Attempting to avoid 'Destination buffer is too small'
 error by creating decoding buffer 3x larger than max size

Signed-off-by: Nick Gerakines <12125+ngerakines@users.noreply.github.com>
---
 src/consumer.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/consumer.rs b/src/consumer.rs
index a35e5f0..b222f1e 100644
--- a/src/consumer.rs
+++ b/src/consumer.rs
@@ -126,7 +126,7 @@ impl ConsumerTask {
                     }
                     let payload = item.into_payload();
 
-                    let decoded = decompressor.decompress(&payload, MAX_MESSAGE_SIZE + 1);
+                    let decoded = decompressor.decompress(&payload, MAX_MESSAGE_SIZE * 3);
                     if let Err(err) = decoded {
                         let length = payload.len();
                         tracing::error!(error = ?err, length = ?length, "error processing jetstream message");
-- 
2.51.2