support flow messages for batch size of 1 (#326)

streamnative · Oct 22, 2024 · 715411c · 715411c
1 parent a4012e8
commit 715411c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/consumer/engine.rs b/src/consumer/engine.rs
@@ -146,7 +146,7 @@ impl<Exe: Executor> ConsumerEngine<Exe> {
                     })?;
             }
 
-            if self.remaining_messages < self.batch_size / 2 {
+            if self.remaining_messages < self.batch_size.div_ceil(2) {
                 match self
                     .connection
                     .sender()