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

…amp' is not set, a NPE will be thrown. (apache#102)
ArthurWrong · Mar 28, 2024 · f48eacf · f48eacf
1 parent 38560d7
commit f48eacf
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")