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) {