AutoOffsetReset = AutoOffsetReset.Latest

vostok · May 28, 2024 · 7d6ee8a · 7d6ee8a
1 parent b56f0be
commit 7d6ee8a
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
@@ -35,7 +35,7 @@ public KafkaTopicReader(KafkaTopicReaderSettings settings, ILog log, BufferPool
         {
             GroupId = this.settings.GroupId,
             BootstrapServers = this.settings.BootstrapServers,
-            AutoOffsetReset = AutoOffsetReset.Earliest,
+            AutoOffsetReset = AutoOffsetReset.Latest,
             EnableAutoCommit = false,
             FetchMinBytes = this.settings.FetchMinBytes,
             FetchWaitMaxMs = this.settings.FetchWaitMaxMs