Hisoka-X commented on code in PR #9318:
URL: https://github.com/apache/seatunnel/pull/9318#discussion_r2094060594
##########
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/config/KafkaSourceOptions.java:
##########
@@ -109,4 +109,11 @@ public class KafkaSourceOptions extends KafkaBaseOptions {
"The processing method of data format error. The
default value is fail, and the optional value is (fail, skip). "
+ "When fail is selected, data format
error will block and an exception will be thrown. "
+ "When skip is selected, data format
error will skip this line data.");
+
+ public static final Option<Long> START_MODE_END_TIMESTAMP =
+ Options.key("start_mode.endTimestamp")
Review Comment:
```suggestion
Options.key("start_mode.end_timestamp")
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
