AutoOffsetReset = AutoOffsetReset.Latest

vostok · May 28, 2024 · 5ad16b4 · 5ad16b4
1 parent 1a6c6ad
commit 5ad16b4
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