Skip to content

Commit b816116

Browse files
authored
1.add required fields in RockeMQ jdbc connector 2. add docs (apache#539)
1 parent cc992db commit b816116

File tree

2 files changed

+9
-5
lines changed

2 files changed

+9
-5
lines changed

rocketmq-connect-jdbc/README.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,4 +57,6 @@ http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-jdbc-connector-name}/
5757
|~~rocketmqTopic~~ | String || 待废弃 | jdbcTopic |
5858
|task-divide-strategy | Integer || task 分配策略, 默认值为 0,表示按照topic分配任务,每一个table便是一个topic | 0 |
5959
|task-parallelism | Integer || task parallelism,默认值为 1,表示将topic拆分为多少个任务进行执行 | 2 |
60+
|source-rocketmq | String || sink 端获取路由信息连接到的RocketMQ nameserver 地址 | TODO |
61+
|source-rocketmq | String || sink 端获取路由信息连接到的RocketMQ broker cluster 地址 | TODO |
6062
|source-record-converter | String || source data 解析 | org.apache.rocketmq.connect.runtime.converter.JsonConverter |

rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -85,12 +85,14 @@ public class Config {
8585
private Logger log = LoggerFactory.getLogger(Config.class);
8686
public static final Set<String> REQUEST_CONFIG = new HashSet<String>() {
8787
{
88-
add("dbUrl");
89-
add("dbPort");
90-
add("dbUsername");
91-
add("dbPassword");
92-
add("mode");
88+
add(CONN_DB_IP);
89+
add(CONN_DB_PORT);
90+
add(CONN_DB_USERNAME);
91+
add(CONN_DB_PASSWORD);
92+
add(CONN_DB_MODE);
9393
add("rocketmqTopic");
94+
add(CONN_SOURCE_RMQ);
95+
add(CONN_SOURCE_CLUSTER);
9496
}
9597
};
9698

0 commit comments

Comments
 (0)