This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
The following commit(s) were added to refs/heads/new-official-website by this
push:
new 951990a93 [ISSUE #454] Translation for "数据集成-RocketMQ Connect实战4"
Section in the v4.x & 5.0 Document (CN -> EN) (#455)
951990a93 is described below
commit 951990a93ec664ab41bd9bd06d9e67b6b0a313b0
Author: mxsm <[email protected]>
AuthorDate: Tue Jan 17 10:52:35 2023 +0800
[ISSUE #454] Translation for "数据集成-RocketMQ Connect实战4" Section in the v4.x
& 5.0 Document (CN -> EN) (#455)
* [ISSUE #454] Translation for "数据集成-RocketMQ Connect实战4" Section in the
v4.x & 5.0 Document (CN -> EN)
* polish document
* polish document
---
.../31RocketMQ Connect In Action4.md" | 150 +++++++++++++++++++++
.../31RocketMQ Connect In Action4.md" | 150 +++++++++++++++++++++
.../31RocketMQ Connect In Action4.md" | 149 ++++++++++++++++++++
3 files changed, 449 insertions(+)
diff --git
"a/i18n/en/docusaurus-plugin-content-docs/current/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
"b/i18n/en/docusaurus-plugin-content-docs/current/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
new file mode 100644
index 000000000..3f0dd0147
--- /dev/null
+++
"b/i18n/en/docusaurus-plugin-content-docs/current/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
@@ -0,0 +1,150 @@
+# RocketMQ Connect in Action 4
+
+SFTP Server(file data) -> RocketMQ Connect
+
+## Preparation
+
+### Start RocketMQ
+
+1. Linux/Unix/Mac
+2. 64bit JDK 1.8+;
+3. Maven 3.2.x+;
+4. Start [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+
+
+
+**Tips** : ${ROCKETMQ_HOME} locational instructions
+
+>bin-release.zip version：/rocketmq-all-4.9.4-bin-release
+>
+>source-release.zip version：/rocketmq-all-4.9.4-source-release/distribution
+
+
+### Start Connect
+
+
+#### **Compiling Connector Plugin**
+
+RocketMQ Connector SFTP
+
+```
+$ cd rocketmq-connect/connectors/rocketmq-connect-sftp/
+$ mvn clean package -Dmaven.test.skip=true
+```
+
+Move the compiled RocketMQ Connector SFTP package into the Runtime loading
directory. The command is as follows:
+
+```
+mkdir -p /usr/local/connector-plugins
+cp target/rocketmq-connect-sftp-0.0.1-SNAPSHOT-jar-with-dependencies.jar
/usr/local/connector-plugins
+```
+
+#### Start Connect Runtime
+
+```
+cd rocketmq-connect
+
+mvn -Prelease-connect -DskipTests clean install -U
+
+```
+
+Modify the configuration `connect-standalone.conf`, the main configuration is
as follows
+
+```
+$ cd
distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
+$ vim conf/connect-standalone.conf
+```
+
+```
+workerId=standalone-worker
+storePathRootDir=/tmp/storeRoot
+
+## Http port for user to access REST API
+httpPort=8082
+
+# Rocketmq namesrvAddr
+namesrvAddr=localhost:9876
+
+# RocketMQ acl
+aclEnable=false
+accessKey=rocketmq
+secretKey=12345678
+
+autoCreateGroupEnable=false
+clusterName="DefaultCluster"
+
+# Core configuration, configure the plugin directory that was previously
compiled here.
+# Source or sink connector jar file dir,The default value is
rocketmq-connect-sample
+pluginPaths=/usr/local/connector-plugins
+```
+
+
+```
+cd
distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
+
+sh bin/connect-standalone.sh -c conf/connect-standalone.conf &
+
+```
+
+### Set up an SFTP server
+
+Use the built-in SFTP server on MAC OS.
+
+[Allow remote computers to access your
Mac](https://support.apple.com/zh-cn/guide/mac-help/mchlp1066/mac)
+
+### Test data
+
+Log in to the SFTP server and place a file called source.txt with specific
contents in the user directory, for example: /path/to/.
+
+```text
+zhangsan|100000202211290001|20221129001|30000.00|2022-11-28|03:00:00|7.00
+lisi|100000202211290002|20221129002|40000.00|2022-11-28|04:00:00|9.00
+zhaowu|100000202211290003|20221129003|50000.00|2022-11-28|05:00:00|12.00
+```
+
+## Start Connector
+
+### Start SFTP source connector
+
+Synchronize the SFTP file: source.txt
+Purpose: by logging into the SFTP server, parsing the file and encapsulating
it into a generic ConnectRecord object, sending it to the RocketMQ Topic.
+
+```shell
+curl -X POST --location "http://localhost:8082/connectors/SftpSourceConnector";
--http1.1 \
+ -H "Host: localhost:8082" \
+ -H "Content-Type: application/json" \
+ -d "{
+ \"connector.class\":
\"org.apache.rocketmq.connect.http.sink.SftpSourceConnector\",
+ \"host\": \"127.0.0.1\",
+ \"port\": 22,
+ \"username\": \"wencheng\",
+ \"password\": \"1617\",
+ \"filePath\": \"/Users/wencheng/Documents/source.txt\",
+ \"connect.topicname\": \"sftpTopic\",
+ \"fieldSeparator\": \"|\",
+ \"fieldSchema\":
\"username|idCardNo|orderNo|orderAmount|trxDate|trxTime|profit\"
+ }"
+```
+
+After running the above commands, the file data on the SFTP server will be
organized into data in the specified format, and written to MQ. Afterwards, it
can be consumed by the sink connector or other business systems.
+
+### Start SFTP sink connector
+
+Purpose: by consuming the data in the Topic, use the SFTP protocol to write to
the target file.
+
+```shell
+curl -X POST --location "http://localhost:8082/connectors/SftpSinkConnector";
--http1.1 \
+ -H "Host: localhost:8082" \
+ -H "Content-Type: application/json" \
+ -d "{
+ \"connector.class\":
\"org.apache.rocketmq.connect.http.sink.SftpSinkConnector\",
+ \"host\": \"127.0.0.1\",
+ \"port\": 22,
+ \"username\": \"wencheng\",
+ \"password\": \"1617\",
+ \"filePath\": \"/Users/wencheng/Documents/sink.txt\",
+ \"connect.topicnames\": \"sftpTopic\",
+ \"fieldSeparator\": \"|\",
+ \"fieldSchema\":
\"username|idCardNo|orderNo|orderAmount|trxDate|trxTime|profit\"
+ }"
+```
diff --git
"a/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
"b/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
new file mode 100644
index 000000000..3f0dd0147
--- /dev/null
+++
"b/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
@@ -0,0 +1,150 @@
+# RocketMQ Connect in Action 4
+
+SFTP Server(file data) -> RocketMQ Connect
+
+## Preparation
+
+### Start RocketMQ
+
+1. Linux/Unix/Mac
+2. 64bit JDK 1.8+;
+3. Maven 3.2.x+;
+4. Start [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+
+
+
+**Tips** : ${ROCKETMQ_HOME} locational instructions
+
+>bin-release.zip version：/rocketmq-all-4.9.4-bin-release
+>
+>source-release.zip version：/rocketmq-all-4.9.4-source-release/distribution
+
+
+### Start Connect
+
+
+#### **Compiling Connector Plugin**
+
+RocketMQ Connector SFTP
+
+```
+$ cd rocketmq-connect/connectors/rocketmq-connect-sftp/
+$ mvn clean package -Dmaven.test.skip=true
+```
+
+Move the compiled RocketMQ Connector SFTP package into the Runtime loading
directory. The command is as follows:
+
+```
+mkdir -p /usr/local/connector-plugins
+cp target/rocketmq-connect-sftp-0.0.1-SNAPSHOT-jar-with-dependencies.jar
/usr/local/connector-plugins
+```
+
+#### Start Connect Runtime
+
+```
+cd rocketmq-connect
+
+mvn -Prelease-connect -DskipTests clean install -U
+
+```
+
+Modify the configuration `connect-standalone.conf`, the main configuration is
as follows
+
+```
+$ cd
distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
+$ vim conf/connect-standalone.conf
+```
+
+```
+workerId=standalone-worker
+storePathRootDir=/tmp/storeRoot
+
+## Http port for user to access REST API
+httpPort=8082
+
+# Rocketmq namesrvAddr
+namesrvAddr=localhost:9876
+
+# RocketMQ acl
+aclEnable=false
+accessKey=rocketmq
+secretKey=12345678
+
+autoCreateGroupEnable=false
+clusterName="DefaultCluster"
+
+# Core configuration, configure the plugin directory that was previously
compiled here.
+# Source or sink connector jar file dir,The default value is
rocketmq-connect-sample
+pluginPaths=/usr/local/connector-plugins
+```
+
+
+```
+cd
distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
+
+sh bin/connect-standalone.sh -c conf/connect-standalone.conf &
+
+```
+
+### Set up an SFTP server
+
+Use the built-in SFTP server on MAC OS.
+
+[Allow remote computers to access your
Mac](https://support.apple.com/zh-cn/guide/mac-help/mchlp1066/mac)
+
+### Test data
+
+Log in to the SFTP server and place a file called source.txt with specific
contents in the user directory, for example: /path/to/.
+
+```text
+zhangsan|100000202211290001|20221129001|30000.00|2022-11-28|03:00:00|7.00
+lisi|100000202211290002|20221129002|40000.00|2022-11-28|04:00:00|9.00
+zhaowu|100000202211290003|20221129003|50000.00|2022-11-28|05:00:00|12.00
+```
+
+## Start Connector
+
+### Start SFTP source connector
+
+Synchronize the SFTP file: source.txt
+Purpose: by logging into the SFTP server, parsing the file and encapsulating
it into a generic ConnectRecord object, sending it to the RocketMQ Topic.
+
+```shell
+curl -X POST --location "http://localhost:8082/connectors/SftpSourceConnector";
--http1.1 \
+ -H "Host: localhost:8082" \
+ -H "Content-Type: application/json" \
+ -d "{
+ \"connector.class\":
\"org.apache.rocketmq.connect.http.sink.SftpSourceConnector\",
+ \"host\": \"127.0.0.1\",
+ \"port\": 22,
+ \"username\": \"wencheng\",
+ \"password\": \"1617\",
+ \"filePath\": \"/Users/wencheng/Documents/source.txt\",
+ \"connect.topicname\": \"sftpTopic\",
+ \"fieldSeparator\": \"|\",
+ \"fieldSchema\":
\"username|idCardNo|orderNo|orderAmount|trxDate|trxTime|profit\"
+ }"
+```
+
+After running the above commands, the file data on the SFTP server will be
organized into data in the specified format, and written to MQ. Afterwards, it
can be consumed by the sink connector or other business systems.
+
+### Start SFTP sink connector
+
+Purpose: by consuming the data in the Topic, use the SFTP protocol to write to
the target file.
+
+```shell
+curl -X POST --location "http://localhost:8082/connectors/SftpSinkConnector";
--http1.1 \
+ -H "Host: localhost:8082" \
+ -H "Content-Type: application/json" \
+ -d "{
+ \"connector.class\":
\"org.apache.rocketmq.connect.http.sink.SftpSinkConnector\",
+ \"host\": \"127.0.0.1\",
+ \"port\": 22,
+ \"username\": \"wencheng\",
+ \"password\": \"1617\",
+ \"filePath\": \"/Users/wencheng/Documents/sink.txt\",
+ \"connect.topicnames\": \"sftpTopic\",
+ \"fieldSeparator\": \"|\",
+ \"fieldSchema\":
\"username|idCardNo|orderNo|orderAmount|trxDate|trxTime|profit\"
+ }"
+```
diff --git
"a/versioned_docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
"b/versioned_docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
new file mode 100644
index 000000000..2a9c439d6
--- /dev/null
+++
"b/versioned_docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/31RocketMQ
Connect In Action4.md"
@@ -0,0 +1,149 @@
+# RocketMQ Connect实战4
+
+SFTP Server(文件数据) -> RocketMQ Connect
+
+## 准备
+
+### 启动RocketMQ
+
+1. Linux/Unix/Mac
+2. 64bit JDK 1.8+;
+3. Maven 3.2.x或以上版本;
+4. 启动 [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+
+
+
+**提示** : ${ROCKETMQ_HOME} 位置说明
+
+>bin-release.zip 版本：/rocketmq-all-4.9.4-bin-release
+>
+>source-release.zip 版本：/rocketmq-all-4.9.4-source-release/distribution
+
+
+### 启动Connect
+
+
+#### Connector插件编译
+
+RocketMQ Connector SFTP
+```
+$ cd rocketmq-connect/connectors/rocketmq-connect-sftp/
+$ mvn clean package -Dmaven.test.skip=true
+```
+
+将 RocketMQ Connector SFTP 编译好的包放入Runtime加载目录。命令如下：
+```
+mkdir -p /usr/local/connector-plugins
+cp target/rocketmq-connect-sftp-0.0.1-SNAPSHOT-jar-with-dependencies.jar
/usr/local/connector-plugins
+```
+
+#### 启动Connect Runtime
+
+```
+cd rocketmq-connect
+
+mvn -Prelease-connect -DskipTests clean install -U
+
+```
+
+修改配置`connect-standalone.conf` ，重点配置如下
+```
+$ cd
distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
+$ vim conf/connect-standalone.conf
+```
+
+```
+workerId=standalone-worker
+storePathRootDir=/tmp/storeRoot
+
+## Http port for user to access REST API
+httpPort=8082
+
+# Rocketmq namesrvAddr
+namesrvAddr=localhost:9876
+
+# RocketMQ acl
+aclEnable=false
+accessKey=rocketmq
+secretKey=12345678
+
+autoCreateGroupEnable=false
+clusterName="DefaultCluster"
+
+# 核心配置，将之前编译好包的插件目录配置在此；
+# Source or sink connector jar file dir,The default value is
rocketmq-connect-sample
+pluginPaths=/usr/local/connector-plugins
+```
+
+
+```
+cd
distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
+
+sh bin/connect-standalone.sh -c conf/connect-standalone.conf &
+
+```
+
+### SFTP 服务器搭建
+
+使用 MAC OS 自带的 SFTP 服务器
+
+[允许远程电脑访问你的 Mac](https://support.apple.com/zh-cn/guide/mac-help/mchlp1066/mac)
+
+### 测试数据
+
+登陆 SFTP 服务器，将具有如何内容的 souce.txt 文件放入用户目录，例如：/path/to/
+
+```text
+张三|100000202211290001|20221129001|30000.00|2022-11-28|03:00:00|7.00
+李四|100000202211290002|20221129002|40000.00|2022-11-28|04:00:00|9.00
+赵五|100000202211290003|20221129003|50000.00|2022-11-28|05:00:00|12.00
+```
+
+## 启动Connector
+
+### 启动 SFTP source connector
+
+同步 SFTP 文件：source.txt
+作用：通过登陆 SFTP 服务器，解析文件并封装成通用的ConnectRecord对象，发送的RocketMQ Topic当中
+
+```shell
+curl -X POST --location "http://localhost:8082/connectors/SftpSourceConnector";
--http1.1 \
+ -H "Host: localhost:8082" \
+ -H "Content-Type: application/json" \
+ -d "{
+ \"connector.class\":
\"org.apache.rocketmq.connect.http.sink.SftpSourceConnector\",
+ \"host\": \"127.0.0.1\",
+ \"port\": 22,
+ \"username\": \"wencheng\",
+ \"password\": \"1617\",
+ \"filePath\": \"/Users/wencheng/Documents/source.txt\",
+ \"connect.topicname\": \"sftpTopic\",
+ \"fieldSeparator\": \"|\",
+ \"fieldSchema\":
\"username|idCardNo|orderNo|orderAmount|trxDate|trxTime|profit\"
+ }"
+```
+
+运行完以上命令后，SFTP 服务上的文件数据会被组织成给定格式的数据，写入 MQ。之后可以通过 sink connector 或者其他业务系统去消费它。
+
+### 启动 SFTP sink connector
+
+作用：通过消费Topic中的数据，使用SFTP协议写入到目标文件当中
+
+```shell
+curl -X POST --location "http://localhost:8082/connectors/SftpSinkConnector";
--http1.1 \
+ -H "Host: localhost:8082" \
+ -H "Content-Type: application/json" \
+ -d "{
+ \"connector.class\":
\"org.apache.rocketmq.connect.http.sink.SftpSinkConnector\",
+ \"host\": \"127.0.0.1\",
+ \"port\": 22,
+ \"username\": \"wencheng\",
+ \"password\": \"1617\",
+ \"filePath\": \"/Users/wencheng/Documents/sink.txt\",
+ \"connect.topicnames\": \"sftpTopic\",
+ \"fieldSeparator\": \"|\",
+ \"fieldSchema\":
\"username|idCardNo|orderNo|orderAmount|trxDate|trxTime|profit\"
+ }"
+```
+
+****
\ No newline at end of file
