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)
                         {