diff --git a/Vostok.Hercules.Consumers/Kafka/KafkaTopicReader.cs b/Vostok.Hercules.Consumers/Kafka/KafkaTopicReader.cs
index a6e2853..50bfe8c 100644
--- a/Vostok.Hercules.Consumers/Kafka/KafkaTopicReader.cs
+++ b/Vostok.Hercules.Consumers/Kafka/KafkaTopicReader.cs
@@ -79,7 +79,7 @@ private RawReadStreamResult ReadInternal(ReadStreamQuery query)
 
             while (eventsCount < query.Limit)
             {
-                message = consumer.Consume(TimeSpan.Zero);
+                message = consumer.Consume(settings.ConsumeTimeout); // TimeSpan.Zero
                 if (message?.Message is null)
                     break;