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