From cb41f2aa89339362e80feff4656245cef22a57cf Mon Sep 17 00:00:00 2001 From: "e.makrushin" Date: Fri, 24 May 2024 19:14:57 +0700 Subject: [PATCH] =?UTF-8?q?=D0=92=D0=B5=D1=80=D0=BD=D1=83=D0=BB=20=D0=BF?= =?UTF-8?q?=D1=80=D0=B8=D0=B2=D1=8F=D0=B7=D0=BA=D1=83=20=D0=BA=20=D0=BD?= =?UTF-8?q?=D1=83=D0=BB=D0=B5=D0=B2=D0=BE=D0=B9=20=D0=BF=D0=B0=D1=80=D1=82?= =?UTF-8?q?=D0=B8=D1=86=D0=B8=D0=B8=20Kafka-=D1=82=D0=BE=D0=BF=D0=B8=D0=BA?= =?UTF-8?q?=D0=B0?= 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 48f08f2..0fd25db 100644 --- a/Vostok.Hercules.Consumers/Kafka/KafkaTopicReader.cs +++ b/Vostok.Hercules.Consumers/Kafka/KafkaTopicReader.cs @@ -23,7 +23,7 @@ internal sealed class KafkaTopicReader private readonly IConsumer consumer; private static readonly DataSize ReadBufferRentSize = 25.Megabytes(); // Approximate size - private static readonly Partition Partition = Partition.Any; + private static readonly Partition Partition = new Partition(0); public KafkaTopicReader(KafkaTopicReaderSettings settings, ILog log, BufferPool bufferPool) {