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

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


The following commit(s) were added to refs/heads/master by this push:
     new 5d37e66  [MINOR] Fix HoodieNotSupportedException description in 
KafkaOffsetGen  (#1615)
5d37e66 is described below

commit 5d37e66b7ee99a4a496261d98e33e3244b9b9a2a
Author: liujinhui <[email protected]>
AuthorDate: Mon May 11 23:14:43 2020 +0800

    [MINOR] Fix HoodieNotSupportedException description in KafkaOffsetGen  
(#1615)
---
 .../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 3c92e8e..39c47a2 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
@@ -193,7 +193,7 @@ public class KafkaOffsetGen {
             fromOffsets = consumer.endOffsets(topicPartitions);
             break;
           default:
-            throw new HoodieNotSupportedException("Auto reset value must be 
one of 'smallest' or 'largest' ");
+            throw new HoodieNotSupportedException("Auto reset value must be 
one of 'earliest' or 'latest' ");
         }
       }
 

Reply via email to