[ISSUE #101] Fix bug, the optional param 'startup.offset.timestamp' i…

…s not set, a NPE will be thrown. (#102)
apache · Nov 15, 2023 · 48e88d7 · 48e88d7
1 parent b9efd1e
commit 48e88d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java b/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java
@@ -86,7 +86,7 @@ public class RocketMQSourceOptions extends RocketMQOptions {
     public static final ConfigOption<Long> OPTIONAL_STARTUP_OFFSET_TIMESTAMP =
             ConfigOptions.key(CONSUMER_PREFIX + "startup.offset.timestamp")
                     .longType()
-                    .noDefaultValue();
+                    .defaultValue(RocketMQConfig.DEFAULT_START_MESSAGE_OFFSET);
 
     public static final ConfigOption<String> OPTIONAL_STOP_OFFSET_TIMESTAMP =
             ConfigOptions.key(CONSUMER_PREFIX + "stop.offset.timestamp")