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' ");
}
}