Skip to content

Commit 1cf284e

Browse files
authored
change kafka consumer auto.offset.reset to earliest
1 parent 060ebf3 commit 1cf284e

File tree

1 file changed

+1
-1
lines changed
  • kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework

1 file changed

+1
-1
lines changed

kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/KafkaStreamsApp.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ public Map<String, Object> getBaseStreamsConfig() {
236236
// Consumer configurations
237237
// ##########################
238238
// default - earliest (kafka streams)
239-
baseStreamsConfig.put(consumerPrefix(AUTO_OFFSET_RESET_CONFIG), "latest");
239+
baseStreamsConfig.put(consumerPrefix(AUTO_OFFSET_RESET_CONFIG), "earliest");
240240
// Increase fetch max wait time for increased throughput, reduced network calls
241241
// default - 500ms
242242
baseStreamsConfig.put(consumerPrefix(FETCH_MAX_WAIT_MS_CONFIG), 5000);

0 commit comments

Comments
 (0)