From 4fa43359cb1f95a0f663bb32b6f479fd85bdb255 Mon Sep 17 00:00:00 2001 From: t0il3ts0ap Date: Wed, 3 Mar 2021 07:19:18 +0530 Subject: [PATCH] [MINOR] Fix default value for hoodie.deltastreamer.source.kafka.auto.reset.offsets (#2617) --- .../apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java index e37ec0a11..7a3f82b07 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java @@ -177,7 +177,7 @@ public class KafkaOffsetGen { } DataSourceUtils.checkRequiredProperties(props, Collections.singletonList(Config.KAFKA_TOPIC_NAME)); topicName = props.getString(Config.KAFKA_TOPIC_NAME); - String kafkaAutoResetOffsetsStr = props.getString(Config.KAFKA_AUTO_RESET_OFFSETS, Config.DEFAULT_KAFKA_AUTO_RESET_OFFSETS.name()); + String kafkaAutoResetOffsetsStr = props.getString(Config.KAFKA_AUTO_RESET_OFFSETS, Config.DEFAULT_KAFKA_AUTO_RESET_OFFSETS.name().toLowerCase()); boolean found = false; for (KafkaResetOffsetStrategies entry: KafkaResetOffsetStrategies.values()) { if (entry.name().toLowerCase().equals(kafkaAutoResetOffsetsStr)) {