edavis.dev
this repo has no description
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>
+1
-1
+1
-1
src/consumer.rs
+1
-1
src/consumer.rs
···
126
126
}
127
127
let payload = item.into_payload();
128
128
129
-
let decoded = decompressor.decompress(&payload, MAX_MESSAGE_SIZE + 1);
129
+
let decoded = decompressor.decompress(&payload, MAX_MESSAGE_SIZE * 3);
130
130
if let Err(err) = decoded {
131
131
let length = payload.len();
132
132
tracing::error!(error = ?err, length = ?length, "error processing jetstream message");