From dd8cfdf461d6a919d4bdb0720502eea6091667f9 Mon Sep 17 00:00:00 2001
From: yufansong <yufan@risingwave-labs.com>
Date: Sun, 17 Sep 2023 22:45:19 -0700
Subject: [PATCH] add max bytes

---
 src/connector/src/common.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/connector/src/common.rs b/src/connector/src/common.rs
index 7a703e7db8a20..550d3e5b627fb 100644
--- a/src/connector/src/common.rs
+++ b/src/connector/src/common.rs
@@ -469,6 +469,7 @@ impl NatsCommon {
         let mut config = jetstream::stream::Config {
             // the subject default use name value
             name: self.subject.clone(),
+            max_bytes: 1000000,
             ..Default::default()
         };
         if let Some(v) = self.max_bytes {