You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:19:19 UTC

[rocketmq-connect] 03/05: fix hudi connect config

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 5da4b78705108ac6d260283cd38f9be08d2590b9
Author: duhenglucky <du...@apache.org>
AuthorDate: Sun Dec 5 21:26:51 2021 +0800

    fix hudi connect config
---
 README.md | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/README.md b/README.md
index 509f3b2..cadc364 100644
--- a/README.md
+++ b/README.md
@@ -44,10 +44,9 @@ http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-hudi-connector-name}/
 |topicNames | String | 是 | rocketmq默认每一个数据源中的表对应一个名字,该名称需和数据库表名称相同 | jdbc_hudi |
 |task-divide-strategy | Integer | 否 | task 分配策略, 默认值为 0,表示按照topic分配任务,每一个table便是一个topic | 0 |
 |task-parallelism | Integer | 否 | task parallelism,默认值为 1,表示将topic拆分为多少个任务进行执行 | 2 |
-|source-cluster | String | 是 | sink 端获取路由信息连接到的RocketMQ nameserver 地址 | 172.17.0.1:10911 |
-|source-rocketmq | String | 是 | sink 端获取路由信息连接到的RocketMQ broker cluster 地址 | 127.0.0.1:9876 |
+|source-cluster | String | 是 | sink 端 RocketMQ cluster 名称 | DefaultCluster |
+|source-rocketmq | String | 是 | sink 端获取路由信息连接到的 RocketMQ nameserver 地址 | 127.0.0.1:9876 |
 |source-record-converter | String | 是 | source data 解析 | org.apache.rocketmq.connect.runtime.converter.RocketMQConverter |
-|src-cluster | String | 否 | 源集群 | DefaultCluster |
 |refresh-interval | String | 否 | sink的刷新时间,单位ms | 10000 |
 |schemaPath | String | 是 | sink的schema地址 | /Users/osgoo/Downloads/user.avsc" |
 
@@ -64,7 +63,7 @@ http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-hudi-connector-name}/
 	"deleteParallelism": "2",
 	"source-record-converter": "org.apache.rocketmq.connect.runtime.converter.RocketMQConverter",
 	"source-rocketmq": "127.0.0.1:9876",
-	"src-cluster": "DefaultCluster",
+	"source-cluster": "DefaultCluster",
 	"refresh-interval": "10000",
 	"schemaPath": "/Users/osgoo/Downloads/user.avsc"
 }