From 9215342f9df34b99b0fe569c6f5930278826b6b9 Mon Sep 17 00:00:00 2001
From: Bazen <49089563+bazen-teklehaymanot@users.noreply.github.com>
Date: Thu, 25 Jan 2024 07:05:23 +0200
Subject: [PATCH 1/2] extended timeout to 20 sec

---
 src/Memphis.Client/Consumer/MemphisConsumerOptions.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs b/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs
index 545e49a..c4bc952 100644
--- a/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs
+++ b/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs
@@ -19,7 +19,7 @@ public sealed class MemphisConsumerOptions
     public int BatchMaxTimeToWaitMs
     {
         get => _batchMaxTimeToWaitMs;
-        set => _batchMaxTimeToWaitMs =  (value < 1000) ? 1000 : value;
+        set => _batchMaxTimeToWaitMs =  (value < 20_000) ? 20_000 : value;
     }
     public int MaxAckTimeMs { get; set; } = 30_000;
     public int MaxMsgDeliveries { get; set; } = 2;

From a9a5d689ccd3ccf850fb88381d94fe7f0fcce351 Mon Sep 17 00:00:00 2001
From: Bazen <49089563+bazen-teklehaymanot@users.noreply.github.com>
Date: Thu, 25 Jan 2024 07:33:54 +0200
Subject: [PATCH 2/2] Updated batchMaxTimeToWaitMs

---
 src/Memphis.Client/Consumer/MemphisConsumerOptions.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs b/src/Memphis.Client/Consumer/MemphisConsumerOptions.cs
index c4bc952..71aaab9 100644
--- 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 = 1000;
+    private int _batchMaxTimeToWaitMs = 20_000;
 
     public string StationName { get; set; }
     public string ConsumerName { get; set; }