_batchMaxTimeToWaitMs 20_000 -> 1_000

superstreamlabs · Feb 7, 2024 · 6f5c93e · 6f5c93e
1 parent 14b9a47
commit 6f5c93e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs b/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs
@@ -4,7 +4,7 @@ namespace Memphis.Client.Consumer;
 
 public sealed class MemphisConsumerOptions
 {
-    private int _batchMaxTimeToWaitMs = 20_000;
+    private int _batchMaxTimeToWaitMs = 1_000;
 
     public string StationName { get; set; }
     public string ConsumerName { get; set; }
@@ -19,7 +19,7 @@ public sealed class MemphisConsumerOptions
     public int BatchMaxTimeToWaitMs
     {
         get => _batchMaxTimeToWaitMs;
-        set => _batchMaxTimeToWaitMs =  (value < 20_000) ? 20_000 : value;
+        set => _batchMaxTimeToWaitMs =  (value < 1_000) ? 1_000 : value;
     }
     public int MaxAckTimeMs { get; set; } = 30_000;
     public int MaxMsgDeliveries { get; set; } = 2;