From 1cf284e57fad07ba6b1d5e83ca404c4a7d98ba72 Mon Sep 17 00:00:00 2001
From: Ravi Singal <62086374+ravisingal@users.noreply.github.com>
Date: Wed, 10 Dec 2025 10:45:13 +0530
Subject: [PATCH] change kafka consumer auto.offset.reset to earliest

---
 .../hypertrace/core/kafkastreams/framework/KafkaStreamsApp.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/KafkaStreamsApp.java b/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/KafkaStreamsApp.java
index 2e95b3e..7f5b840 100644
--- a/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/KafkaStreamsApp.java
+++ b/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/KafkaStreamsApp.java
@@ -236,7 +236,7 @@ public Map<String, Object> getBaseStreamsConfig() {
     // Consumer configurations
     // ##########################
     // default - earliest (kafka streams)
-    baseStreamsConfig.put(consumerPrefix(AUTO_OFFSET_RESET_CONFIG), "latest");
+    baseStreamsConfig.put(consumerPrefix(AUTO_OFFSET_RESET_CONFIG), "earliest");
     // Increase fetch max wait time for increased throughput, reduced network calls
     // default - 500ms
     baseStreamsConfig.put(consumerPrefix(FETCH_MAX_WAIT_MS_CONFIG), 5000);