This is an automated email from the ASF dual-hosted git repository.
sunxiaojian 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 e29c1c12 improve jdbc connector docs (#516)
e29c1c12 is described below
commit e29c1c125306562d56a20f3f78ba6b1ec2980b4f
Author: Ziyi Tan <[email protected]>
AuthorDate: Fri Aug 4 19:29:05 2023 +0800
improve jdbc connector docs (#516)
Signed-off-by: Ziy1-Tan <[email protected]>
---
README.md | 11 +++--------
.../rocketmq-connect-debezium-mysql/README.md | 8 +++-----
.../rocketmq-connect-debezium-postgresql/README.md | 8 +++-----
connectors/rocketmq-connect-jdbc/README.md | 2 +-
4 files changed, 10 insertions(+), 19 deletions(-)
diff --git a/README.md b/README.md
index 89b7b2e3..37ae98ce 100644
--- a/README.md
+++ b/README.md
@@ -115,7 +115,7 @@ cat test-sink-file.txt
| connect.topicnames | false | | sink需要处理数据消息topics
|
```
-注：source/sink配置文件说明是以rocketmq-connect-sample为demo，不同source/sink
connector配置有差异，请以具体sourc/sink connector 为准
+注：source/sink配置文件说明是以rocketmq-connect-sample为demo，不同source/sink
connector配置有差异，请以具体source/sink connector 为准
```
## 6.停止connector
@@ -366,9 +366,9 @@ public interface Transform<R extends ConnectRecord> extends
Component {
| key | nullable | standalone | distributed | default
| description
|
|-----------------------------|----------|------------|-------------|--------------------------------------------------------------------|---------------------------------------------------|
| workerId | false | ✅ ️ | ✅ |
DEFAULT_WORKER_1 | 集群节点唯一标识
|
-| namesrvAddr | false | ✅ | ✅ |
loacalhost:9876 | RocketMQ
Name Server地址列表，多个NameServer地址用分号隔开 |
+| namesrvAddr | false | ✅ | ✅ |
localhost:9876 | RocketMQ
Name Server地址列表，多个NameServer地址用分号隔开 |
| httpPort | false | ✅ | ✅ | 8082
|
runtime提供restful接口服务端口 |
-| pluginPaths | false | ✅ | ✅ |
|
source或者sink目录，启动runttime时加载 |
+| pluginPaths | false | ✅ | ✅ |
|
source或者sink目录，启动runtime时加载 |
| storePathRootDir | true | ✅ | ✅ |
/tmp/connectorStore | 持久化文件保存目录
|
| positionStoreTopic | true | ❌ | ✅ |
connector-position-topic |
source端position变更通知topic |
| positionPersistInterval | true | ✅ | ✅ | 20s
|
source端持久化position数据间隔 |
@@ -498,8 +498,3 @@ Program arguments配置
Environment variables配置
>CONNECT_HOME=${user path}/rocketmq-connect/distribution
-
-
-
-
-
diff --git
a/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/README.md
b/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/README.md
index 8a0ac7a9..47d5cb0f 100644
---
a/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/README.md
+++
b/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/README.md
@@ -144,7 +144,7 @@ INSERT INTO `employee` VALUES (15, NULL, 0, 0, NULL, 0,
NULL, '2022-06-14 20:13:
-use
+use
```
目标库：inventory_2.employee
@@ -208,9 +208,9 @@ curl-X POST-H"Content-Type: application/json"http:
//127.0.0.1:8082/connectors/M
```
curl -X POST -H "Content-Type: application/json"
http://127.0.0.1:8082/connectors/jdbcmysqlsinktest -d '{
- "connector.class":
"org.apache.rocketmq.connect.jdbc.connector.JdbcSinkConnector",
+ "connector.class": "org.apache.rocketmq.connect.jdbc.sink.JdbcSinkConnector",
"max.tasks": "2",
- "connect.topicnames": "debezium-mysql-source",
+ "connect.topicnames": "debezium-MySQL-source-topic",
"connection.url": "jdbc:mysql://数据库ip:3306/inventory_2",
"connection.user": "root",
"connection.password": "debezium",
@@ -235,5 +235,3 @@ curl -X POST -H "Content-Type: application/json"
http://127.0.0.1:8082/connector
对源数据库表：inventory.employee增删改
即可同步到目标办inventory_2.employee
-
-
diff --git
a/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-postgresql/README.md
b/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-postgresql/README.md
index 97fc188d..1f17a2f9 100644
---
a/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-postgresql/README.md
+++
b/connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-postgresql/README.md
@@ -1,6 +1,6 @@
# DEMO
-PostgreSQL Source(CDC) - >RocketMQ Connect -> MySQL Sink(JDBC)
+PostgreSQL Source(CDC) -> RocketMQ Connect -> MySQL Sink(JDBC)
## 准备
@@ -201,7 +201,7 @@ curl -X POST -H "Content-Type: application/json"
http://127.0.0.1:8082/connector
```
curl -X POST -H "Content-Type: application/json"
http://127.0.0.1:8082/connectors/jdbcmysqlsinktest201 -d '{
- "connector.class":
"org.apache.rocketmq.connect.jdbc.connector.JdbcSinkConnector",
+ "connector.class": "org.apache.rocketmq.connect.jdbc.sink.JdbcSinkConnector",
"max.tasks": "2",
"connect.topicnames": "debezium-postgres-source-01",
"connection.url": "jdbc:mysql://数据库ip:3306/bank1",
@@ -227,7 +227,5 @@ curl -X POST -H "Content-Type: application/json"
http://127.0.0.1:8082/connector
通过start_data_engineer/password账号登录数据库
账号登录数据库
-对源数据库表：bankholding增删改
+对源数据库表：bank.holding增删改
即可同步到目标表bank1.holding
-
-
diff --git a/connectors/rocketmq-connect-jdbc/README.md
b/connectors/rocketmq-connect-jdbc/README.md
index 1ed4cd29..bd55b8b8 100644
--- a/connectors/rocketmq-connect-jdbc/README.md
+++ b/connectors/rocketmq-connect-jdbc/README.md
@@ -27,7 +27,7 @@
-## 示例：jdbc -> Rocketmq -> doirs
+## 示例：jdbc -> Rocketmq -> doris
注: 目前支持将根据mysql ,openMLDB对应的source connect以流式的方式导入到rocketmq中的数据导入到doris
