add max bytes

risingwavelabs · Sep 18, 2023 · dd8cfdf · dd8cfdf
1 parent ddbf1f3
commit dd8cfdf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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 {