This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 5420e44a476b726faf88d4c313dc10e11574702d Author: affe <[email protected]> AuthorDate: Sun Mar 29 22:08:12 2020 -0700 1.add required fields in RockeMQ jdbc connector 2. add docs (#539) --- README.md | 2 ++ .../java/org/apache/rocketmq/connect/jdbc/config/Config.java | 12 +++++++----- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/README.md b/README.md index 7b3d397..747e718 100644 --- a/README.md +++ b/README.md @@ -57,4 +57,6 @@ http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-jdbc-connector-name}/ |~~rocketmqTopic~~ | String | 是 | 待废弃 | jdbcTopic | |task-divide-strategy | Integer | 否 | task 分配策略, 默认值为 0，表示按照topic分配任务，每一个table便是一个topic | 0 | |task-parallelism | Integer | 否 | task parallelism，默认值为 1，表示将topic拆分为多少个任务进行执行 | 2 | +|source-rocketmq | String | 是 | sink 端获取路由信息连接到的RocketMQ nameserver 地址 | TODO | +|source-rocketmq | String | 是 | sink 端获取路由信息连接到的RocketMQ broker cluster 地址 | TODO | |source-record-converter | String | 是 | source data 解析 | org.apache.rocketmq.connect.runtime.converter.JsonConverter | diff --git a/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java b/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java index 7b4aca3..cca1aa5 100644 --- a/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java +++ b/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java @@ -85,12 +85,14 @@ public class Config { private Logger log = LoggerFactory.getLogger(Config.class); public static final Set<String> REQUEST_CONFIG = new HashSet<String>() { { - add("dbUrl"); - add("dbPort"); - add("dbUsername"); - add("dbPassword"); - add("mode"); + add(CONN_DB_IP); + add(CONN_DB_PORT); + add(CONN_DB_USERNAME); + add(CONN_DB_PASSWORD); + add(CONN_DB_MODE); add("rocketmqTopic"); + add(CONN_SOURCE_RMQ); + add(CONN_SOURCE_CLUSTER); } };
