From e60a4c032c676c3c578d69968ecbee481564d64d Mon Sep 17 00:00:00 2001
From: "furkan.kavraz" <furkan.kavraz@trendyol.com>
Date: Sun, 19 May 2024 20:36:46 +0300
Subject: [PATCH] #29 increases message consume timeout limit

---
 src/Services/Implementations/KafkaRetryJobService.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Services/Implementations/KafkaRetryJobService.cs b/src/Services/Implementations/KafkaRetryJobService.cs
index 9269772..d899a88 100644
--- a/src/Services/Implementations/KafkaRetryJobService.cs
+++ b/src/Services/Implementations/KafkaRetryJobService.cs
@@ -95,7 +95,7 @@ Action<IConsumer<string,string>, ConsumeResult<string,string>> consumerCommitStr
                     
                     while (currentLag > 0 && messageConsumeLimitPerTopic > 0)
                     {
-                        var result = consumer.Consume(TimeSpan.FromSeconds(3));
+                        var result = consumer.Consume(TimeSpan.FromSeconds(10));
 
                         if (result is null)
                         {