Trendyol#29 increases message consume timeout limit

ahmetfurkankavraz · May 19, 2024 · e60a4c0 · e60a4c0
1 parent e160087
commit e60a4c0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
                         {