Вернул привязку к нулевой партиции Kafka-топика

vostok · May 24, 2024 · cb41f2a · cb41f2a
1 parent 7f0fb20
commit cb41f2a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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<Ignore, byte[]> 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)
     {