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