This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
The following commit(s) were added to refs/heads/master by this push:
new 7ca5dd5 [ISSUE #284] Update Jdbc connector README (#285)
7ca5dd5 is described below
commit 7ca5dd58b4cb55db95fe3bcbd313afc796e6b4fc
Author: Oliver <[email protected]>
AuthorDate: Thu Aug 25 08:32:52 2022 +0800
[ISSUE #284] Update Jdbc connector README (#285)
---
connectors/rocketmq-connect-jdbc/README.md | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/connectors/rocketmq-connect-jdbc/README.md
b/connectors/rocketmq-connect-jdbc/README.md
index cf7ca7b..d295290 100644
--- a/connectors/rocketmq-connect-jdbc/README.md
+++ b/connectors/rocketmq-connect-jdbc/README.md
@@ -19,14 +19,16 @@ POST
http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-jdbc-source-con
{
"connector-class":"org.apache.rocketmq.connect.jdbc.connector.JdbcSourceConnector",
"max-task":"2",
- "connection.url":"jdbc:mysql://XXXXXXXXX:3306",
+ "connection.url":"jdbc:mysql://XXXXXXXXX:3306/{sourceDbName}",
"connection.user":"*****",
"connection.password":"*****",
"table.whitelist":"db.table",
"mode": "incrementing",
"incrementing.column.name":"id",
"timestamp.initial": -1,
-
"source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"
+ "connect-topicname":"targetTopic",
+
"key-converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+
"value-converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
}
```
@@ -37,14 +39,15 @@ POST
http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-jdbc-sink-conne
{
"connector-class":"org.apache.rocketmq.connect.jdbc.connector.JdbcSinkConnector",
"max-task":"2",
- "connect-topicname":"connect-topicname-jdbc-02",
- "connection.url":"jdbc:mysql://*****:3306/{dbname}",
+ "connect-topicname":"targetTopic",
+ "connection.url":"jdbc:mysql://*****:3306/{sinkDbName}",
"connection.user":"******",
"connection.password":"******",
"pk.fields":"id",
"pk.mode":"record_value",
"insert.mode":"UPSERT",
-
"source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"
+
"key-converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+
"value-converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
}
```
