[rocketmq-connect] 35/43: 1.add required fields in RockeMQ jdbc connector 2. add docs (#539)

[zh...@apache.org]

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 <af...@gmail.com>
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);
         }
     };