[hudi] branch master updated: [MINOR] Fix default value for hoodie.deltastreamer.source.kafka.auto.reset.offsets (#2617)

[vinoyang]

This is an automated email from the ASF dual-hosted git repository.

vinoyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 4fa4335  [MINOR] Fix default value for 
hoodie.deltastreamer.source.kafka.auto.reset.offsets (#2617)
4fa4335 is described below

commit 4fa43359cb1f95a0f663bb32b6f479fd85bdb255
Author: t0il3ts0ap <anoop_narang2...@yahoo.com>
AuthorDate: Wed Mar 3 07:19:18 2021 +0530

    [MINOR] Fix default value for 
hoodie.deltastreamer.source.kafka.auto.reset.offsets (#2617)
---
 .../java/org/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 e37ec0a..7a3f82b 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)) {