Вернул привязку к нулевой партиции 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)
  {