Skip to content

Commit 8e00b74

Browse files
authored
change kafka consumer auto.offset.reset to earliest (#112)
1 parent 6bead09 commit 8e00b74

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

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

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
@@ -261,7 +261,7 @@ public Map<String, Object> getBaseStreamsConfig() {
261261
// Consumer configurations
262262
// ##########################
263263
// default - earliest (kafka streams)
264-
baseStreamsConfig.put(consumerPrefix(AUTO_OFFSET_RESET_CONFIG), "latest");
264+
baseStreamsConfig.put(consumerPrefix(AUTO_OFFSET_RESET_CONFIG), "earliest");
265265
// Increase fetch max wait time for increased throughput, reduced network calls
266266
// default - 500ms
267267
baseStreamsConfig.put(consumerPrefix(FETCH_MAX_WAIT_MS_CONFIG), 5000);

0 commit comments

Comments
 (0)