From 5d37e66b7ee99a4a496261d98e33e3244b9b9a2a Mon Sep 17 00:00:00 2001 From: liujinhui <965147871@qq.com> Date: Mon, 11 May 2020 23:14:43 +0800 Subject: [PATCH] [MINOR] Fix HoodieNotSupportedException description in KafkaOffsetGen (#1615) --- .../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 3c92e8e8a..39c47a2c3 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' "); } }