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/04/06 03:34:22 UTC
[rocketmq-connect] branch master updated: [ISSUE #49] Update inconsistent parameters of FileSourceConnector and FileSinkConnector in readme (#50)
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
The following commit(s) were added to refs/heads/master by this push:
new 92d1eec [ISSUE #49] Update inconsistent parameters of FileSourceConnector and FileSinkConnector in readme (#50)
92d1eec is described below
commit 92d1eec300e626f248c5c3055b0e3d2d88d19aab
Author: sunxi92 <su...@163.com>
AuthorDate: Wed Apr 6 11:34:18 2022 +0800
[ISSUE #49] Update inconsistent parameters of FileSourceConnector and FileSinkConnector in readme (#50)
---
README.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/README.md b/README.md
index 4a0077c..7ceb487 100644
--- a/README.md
+++ b/README.md
@@ -88,7 +88,7 @@ connector-position-topic source数据处理进度
```
GET请求
- http://(your worker ip):(port)/connectors/(connector name)?config={"connector-class":"org.apache.rocketmq.connect.file.FileSourceConnector","topic":"fileTopic","filename":"/home/connect/rocketmq-externals/rocketmq-connect/rocketmq-connect-runtime/source-file.txt","source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"}
+ http://(your worker ip):(port)/connectors/(connector name)?config={"connector-class":"org.apache.rocketmq.connect.file.FileSourceConnector","connect-topicname":"fileTopic","filename":"/home/connect/rocketmq-externals/rocketmq-connect/rocketmq-connect-runtime/source-file.txt","source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"}
```
看到一下日志说明file source connector启动成功了
@@ -104,7 +104,7 @@ connector-position-topic source数据处理进度
| connector-class | false | | 实现Connector接口的类名称（包含包名） |
| filename | false | | 数据源文件名称 |
| task-class | false | | 实现SourceTask类名称（包含包名） |
-| topic | false | | 同步文件数据所需topic |
+| connect-topicname | false | | 同步文件数据所需topic |
| update-timestamp | false | | 配置更新时间戳 |
| source-record-converter | false | | Full class name of the impl of the converter used to convert SourceDataEntry to byte[] |
@@ -127,7 +127,7 @@ connector-position-topic source数据处理进度
| key | nullable | default | description |
| ----------------------- | -------- | ------- | -------------------------------------------------------------------------------------- |
| connector-class | false | | 实现Connector接口的类名称（包含包名） |
-| topicNames | false | | sink需要处理数据消息topics |
+| connect-topicname | false | | sink需要处理数据消息topics |
| task-class | false | | 实现SourceTask类名称（包含包名） |
| filename | false | | sink拉去的数据保存到文件 |
| update-timestamp | false | | 配置更新时间戳 |