This is an automated email from the ASF dual-hosted git repository. zhangmang pushed a commit to branch kafka-option-name in repository https://gitbox.apache.org/repos/asf/auron.git
commit 9f3c5b1da145244d4d752ba8cb4d57a9e8018f84 Author: zhangmang <[email protected]> AuthorDate: Tue Mar 24 14:55:01 2026 +0800 [AURON #2059] Optimize option names to align with the Flink community Optimize option names to align with the Flink community --- .../auron/flink/connector/kafka/AuronKafkaDynamicTableFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/flink/connector/kafka/AuronKafkaDynamicTableFactory.java b/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/flink/connector/kafka/AuronKafkaDynamicTableFactory.java index 939e3c67..1d36c6b1 100644 --- a/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/flink/connector/kafka/AuronKafkaDynamicTableFactory.java +++ b/auron-flink-extension/auron-flink-runtime/src/main/java/org/apache/auron/flink/connector/kafka/AuronKafkaDynamicTableFactory.java @@ -81,7 +81,7 @@ public class AuronKafkaDynamicTableFactory implements DynamicTableSourceFactory .defaultValue("") .withDescription("Protobuf fields to skip when deserializing. The format is: field1,field2,field3"); - public static final ConfigOption<String> START_UP_MODE = ConfigOptions.key("start-up.mode") + public static final ConfigOption<String> START_UP_MODE = ConfigOptions.key("scan.startup.mode") .stringType() .defaultValue("GROUP_OFFSET") .withDescription(
