From 465b9f944335e08c235292403804bd3234eb350f Mon Sep 17 00:00:00 2001
From: "e.makrushin" <e.makrushin@skbkontur.ru>
Date: Wed, 29 May 2024 18:17:51 +0700
Subject: [PATCH] =?UTF-8?q?=D0=9F=D0=BE=D0=BF=D1=80=D0=BE=D0=B1=D0=BE?=
 =?UTF-8?q?=D0=B2=D0=B0=D0=BB=20=D1=83=D0=B1=D1=80=D0=B0=D1=82=D1=8C=20?=
 =?UTF-8?q?=D0=BA=D0=BE=D1=81=D1=82=D1=8B=D0=BB=D1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Vostok.Hercules.Consumers/Kafka/KafkaTopicReader.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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;