You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ol...@apache.org on 2023/01/16 03:11:12 UTC
[rocketmq-site] branch new-official-website updated: [ISSUE #379]Translation for "数据集成-快速开始" Section in the v4.x & 5.0 Document (CN -> EN) (#439)
This is an automated email from the ASF dual-hosted git repository.
oliverwqcwrw 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 0c1a8c688 [ISSUE #379]Translation for "数据集成-快速开始" Section in the v4.x & 5.0 Document (CN -> EN) (#439)
0c1a8c688 is described below
commit 0c1a8c6884a7899cf68be72c3ea7dd53e664fec2
Author: mxsm <lj...@gmail.com>
AuthorDate: Mon Jan 16 11:11:07 2023 +0800
[ISSUE #379]Translation for "数据集成-快速开始" Section in the v4.x & 5.0 Document (CN -> EN) (#439)
* [ISSUE #379]Translation for "数据集成-快速开始" Section in the v4.x & 5.0 Document (CN -> EN)
---
.../27RocketMQ Connect Quick Start.md" | 127 +++++++++++----------
.../27RocketMQ Connect Quick Start.md" | 127 +++++++++++----------
2 files changed, 128 insertions(+), 126 deletions(-)
diff --git "a/i18n/en/docusaurus-plugin-content-docs/current/08-\346\225\260\346\215\256\351\233\206\346\210\220/27RocketMQ Connect Quick Start.md" "b/i18n/en/docusaurus-plugin-content-docs/current/08-\346\225\260\346\215\256\351\233\206\346\210\220/27RocketMQ Connect Quick Start.md"
index 31c958953..b6a0c363f 100644
--- "a/i18n/en/docusaurus-plugin-content-docs/current/08-\346\225\260\346\215\256\351\233\206\346\210\220/27RocketMQ Connect Quick Start.md"
+++ "b/i18n/en/docusaurus-plugin-content-docs/current/08-\346\225\260\346\215\256\351\233\206\346\210\220/27RocketMQ Connect Quick Start.md"
@@ -1,31 +1,29 @@
-# 快速开始
+# RocketMQ Connect Quick Start
-[](https://www.apache.org/licenses/LICENSE-2.0.html)
+# Quick Start
-# 快速开始
+In standalone mode, [rocketmq-connect-sample] serves as a demo.
-单机模式下[rocketmq-connect-sample]作为 demo
+The main purpose of rocketmq-connect-sample is to read data from a source file and send it to a RocketMQ cluster, and then read messages from the Topic and write them to a target file.
-rocketmq-connect-sample的主要作用是从源文件中读取数据发送到RocketMQ集群 然后从Topic中读取消息，写入到目标文件
-
-## 1.准备
+## 1. Prepare
1. Linux/Unix/Mac
2. 64bit JDK 1.8+;
-3. Maven 3.2.x或以上版本;
-4. 启动 [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
-5. 创建测试Topic
-> sh ${ROCKETMQ_HOME}/bin/mqadmin updateTopic -t fileTopic -n localhost:9876 -c DefaultCluster -r 8 -w 8
+3. Maven 3.2.x+;
+4. Start [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+5. Create test Topic
+> sh ${ROCKETMQ_HOME}/bin/mqadmin updateTopic -t fileTopic -n localhost:9876 -c DefaultCluster -r 8 -w 8
-**tips** : ${ROCKETMQ_HOME} 位置说明
+**tips** : ${ROCKETMQ_HOME} locational instructions
->bin-release.zip 版本：/rocketmq-all-4.9.4-bin-release
+>bin-release.zip version：/rocketmq-all-4.9.4-bin-release
>
->source-release.zip 版本：/rocketmq-all-4.9.4-source-release/distribution
+>source-release.zip version：/rocketmq-all-4.9.4-source-release/distribution
-## 2.构建Connect
+## 2. Build Connect
```
git clone https://github.com/apache/rocketmq-connect.git
@@ -36,7 +34,7 @@ mvn -Prelease-connect -DskipTests clean install -U
```
-## 3.运行Worker
+## 3. Run Worker
```
cd distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
@@ -44,23 +42,25 @@ cd distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SN
sh bin/connect-standalone.sh -c conf/connect-standalone.conf &
```
-**tips**: 可修改 /bin/runconnect.sh 适当调整 JVM Parameters Configuration
+
+**tips**: The JVM Parameters Configuration can be adjusted in /bin/runconnect.sh as needed.
>JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"
-runtime启动成功：
+runtime start successful：
>The standalone worker boot success.
-查看启动日志文件：
+View the startup log files.
>tail -100f ~/logs/rocketmqconnect/connect_runtime.log
-ctrl + c 退出日志
+`ctrl + c` exit log
-## 4.启动source connector
+## 4. Start source connector
+
+Create a test file named test-source-file.txt in the current directory.
-当前目录创建测试文件 test-source-file.txt
```
touch test-source-file.txt
@@ -69,22 +69,22 @@ echo "Hello \r\nRocketMQ\r\n Connect" >> test-source-file.txt
curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/fileSourceConnector -d '{"connector.class":"org.apache.rocketmq.connect.file.FileSourceConnector","filename":"test-source-file.txt","connect.topicname":"fileTopic"}'
```
-看到以下日志说明 file source connector 启动成功了
+If you see the following log message, it means the file source connector has started successfully.
>tail -100f ~/logs/rocketmqconnect/connect_runtime.log
>
>2019-07-16 11:18:39 INFO pool-7-thread-1 - **Source task start**, config:{"properties":{"source-record-...
-#### source connector配置说明
+#### source connector configuration instructions
-| key | nullable | default | description |
-|-------------------| -------- | ---------------------|--------------------------|
-| connector.class | false | | 实现 Connector接口的类名称（包含包名） |
-| filename | false | | 数据源文件名称 |
-| connect.topicname | false | | 同步文件数据所需topic |
+| key | nullable | default | description |
+| ----------------- | -------- | ------- | ------------------------------------------------------------ |
+| connector.class | false | | The class name (including the package name) that implements the Connector interface |
+| filename | false | | source file name |
+| connect.topicname | false | | Topic required for synchronizing file data |
-## 5.启动sink connector
+## 5. Start sink connector
```
curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/fileSinkConnector -d '{"connector.class":"org.apache.rocketmq.connect.file.FileSinkConnector","filename":"test-sink-file.txt","connect.topicnames":"fileTopic"}'
@@ -95,68 +95,70 @@ cat test-sink-file.txt
> tail -100f ~/logs/rocketmqconnect/connect_runtime.log
-看到以下日志说明file sink connector 启动成功了
+If you see the following log message, it means the file sink connector has started successfully.
> 2019-07-16 11:24:58 INFO pool-7-thread-2 - **Sink task start**, config:{"properties":{"source-record-...
-如果 test-sink-file.txt 生成并且与 source-file.txt 内容一样，说明整个流程正常运行。
-文件内容可能顺序不一样，这主要是因为RocketMQ发到不同queue时，接收不同queue消息顺序可能也不一致导致的，是正常的。
+If test-sink-file.txt is generated and its content is the same as source-file.txt, it means that the entire process is running normally.
+
+The file contents may be in a different order, which is normal because the order of messages received from different queues in RocketMQ may also be inconsistent.
-#### sink connector配置说明
+#### sink connector configuration instructions
-| key | nullable | default | description |
-|--------------------| -------- | ------- | -------------------------------------------------------------------------------------- |
-| connector.class | false | | 实现Connector接口的类名称（包含包名） |
-| filename | false | | sink拉去的数据保存到文件 |
-| connect.topicnames | false | | sink需要处理数据消息topics |
+| key | nullable | default | description |
+| ------------------ | -------- | ------- | ------------------------------------------------------------ |
+| connector.class | false | | The class name (including the package name) that implements the Connector interface |
+| filename | false | | The sink pulls data and saves it to a file. |
+| connect.topicnames | false | | The topics of the data messages that the sink needs to process. |
```
-注：source/sink配置文件说明是以rocketmq-connect-sample为demo，不同source/sink connector配置有差异，请以具体sourc/sink connector 为准
+Tips：The configuration file instructions for the sample rocketmq-connect-sample are for reference only, different source/sink connectors have different configurations, please refer to the specific source/sink connector.
```
-## 6.停止connector
+## 6. Stop connector
```shell
-GET请求
+#GET request
http://(your worker ip):(port)/connectors/(connector name)/stop
-停止demo中的两个connector
+#Stopping the two connectors in the demo
curl http://127.0.0.1:8082/connectors/fileSinkConnector/stop
curl http://127.0.0.1:8082/connectors/fileSourceConnector/stop
```
-看到以下日志说明connector停止成功了
+
+Seeing the following log message indicates that the connector has been successfully stopped.
>**Source task stop**, config:{"properties":{"source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter","filename":"/home/zhoubo/IdeaProjects/my-new3-rocketmq-externals/rocketmq-connect/rocketmq-connect-runtime/source-file.txt","task-class":"org.apache.rocketmq.connect.file.FileSourceTask","topic":"fileTopic","connector-class":"org.apache.rocketmq.connect.file.FileSourceConnector","update-timestamp":"1564765189322"}}
-## 7.停止Worker进程
+## 7. Stopping the Worker process
```
sh bin/connectshutdown.sh
```
-## 8.日志目录
+## 8. Log directory
>${user.home}/logs/rocketmqconnect
-## 9.配置文件
+## 9. Configuration file
-持久化配置文件默认目录 /tmp/storeRoot
+The default directory for persistent configuration files is /tmp/storeRoot.
-| key | description |
-|----------------------|---------------------------|
-| connectorConfig.json | connector配置持久化文件 |
-| position.json | source connect数据处理进度持久化文件 |
-| taskConfig.json | task配置持久化文件 |
-| offset.json | sink connect数据消费进度持久化文件 |
-| connectorStatus.json | connector 状态持久化文件 |
-| taskStatus.json | task 状态持久化文件 |
+| key | description |
+| -------------------- | --------------------------------------------------------- |
+| connectorConfig.json | Connector configuration persistence files |
+| position.json | Source connect data processing progress persistence files |
+| taskConfig.json | Task configuration persistence files |
+| offset.json | Sink connect data consumption progress persistence files |
+| connectorStatus.json | Connector status persistence files |
+| taskStatus.json | Task status persistence files |
-## 10.配置说明
+## 10. Configuration Instructions
-可根据使用情况修改 [RESTful](https://restfulapi.cn/) 端口，storeRoot 路径，Nameserver 地址等信息
+Modify the RESTful port, storeRoot path, Nameserver address, and other information based on your usage.
-文件位置：work 启动目录下 conf/connect-standalone.conf
+The file location is in the conf/connect-standalone.conf under the work startup directory.
```shell
#current cluster node uniquely identifies
@@ -168,15 +170,14 @@ httpPort=8082
# Local file dir for config store
storePathRootDir=/home/connect/storeRoot
-#需要修改为自己的rocketmq nameserver 接入点
+#You need to modify it to your own rocketmq nameserver endpoint.
# RocketMQ namesrvAddr
namesrvAddr=127.0.0.1:9876
-#用于加载Connector插件，类似于jvm启动加载jar包或者class类，这里目录目录用于放Connector相关的实现插件，
-支持文件和目录
+#This is used for loading Connector plugins, similar to how JVM loads jar packages or classes at startup. This directory is used for placing Connector-related implementation plugins and supports both files and directories.
# Source or sink connector jar file dir
pluginPaths=rocketmq-connect-sample/target/rocketmq-connect-sample-0.0.1-SNAPSHOT.jar
-# 补充：将 Connector 相关实现插件保存到指定文件夹
+# Addition : put the Connector-related implementation plugins in the specified folder.
# pluginPaths=/usr/local/connector-plugins/*
```
\ No newline at end of file
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/27RocketMQ Connect Quick Start.md" "b/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/27RocketMQ Connect Quick Start.md"
index 31c958953..8136302a4 100644
--- "a/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/27RocketMQ Connect Quick Start.md"
+++ "b/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-\346\225\260\346\215\256\351\233\206\346\210\220/27RocketMQ Connect Quick Start.md"
@@ -1,31 +1,29 @@
-# 快速开始
+# RocketMQ Connect Quick Start
-[](https://www.apache.org/licenses/LICENSE-2.0.html)
+# Quick Start
-# 快速开始
+In standalone mode, [rocketmq-connect-sample] serves as a demo.
-单机模式下[rocketmq-connect-sample]作为 demo
+The main purpose of rocketmq-connect-sample is to read data from a source file and send it to a RocketMQ cluster, and then read messages from the Topic and write them to a target file.
-rocketmq-connect-sample的主要作用是从源文件中读取数据发送到RocketMQ集群 然后从Topic中读取消息，写入到目标文件
-
-## 1.准备
+## 1. Prepare
1. Linux/Unix/Mac
2. 64bit JDK 1.8+;
-3. Maven 3.2.x或以上版本;
-4. 启动 [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
-5. 创建测试Topic
-> sh ${ROCKETMQ_HOME}/bin/mqadmin updateTopic -t fileTopic -n localhost:9876 -c DefaultCluster -r 8 -w 8
+3. Maven 3.2.x+;
+4. Start [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+5. Create test Topic
+> sh ${ROCKETMQ_HOME}/bin/mqadmin updateTopic -t fileTopic -n localhost:9876 -c DefaultCluster -r 8 -w 8
-**tips** : ${ROCKETMQ_HOME} 位置说明
+**tips** : ${ROCKETMQ_HOME} locational instructions
->bin-release.zip 版本：/rocketmq-all-4.9.4-bin-release
+>bin-release.zip version：/rocketmq-all-4.9.4-bin-release
>
->source-release.zip 版本：/rocketmq-all-4.9.4-source-release/distribution
+>source-release.zip version：/rocketmq-all-4.9.4-source-release/distribution
-## 2.构建Connect
+## 2. Build Connect
```
git clone https://github.com/apache/rocketmq-connect.git
@@ -36,7 +34,7 @@ mvn -Prelease-connect -DskipTests clean install -U
```
-## 3.运行Worker
+## 3. Run Worker
```
cd distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SNAPSHOT
@@ -44,23 +42,25 @@ cd distribution/target/rocketmq-connect-0.0.1-SNAPSHOT/rocketmq-connect-0.0.1-SN
sh bin/connect-standalone.sh -c conf/connect-standalone.conf &
```
-**tips**: 可修改 /bin/runconnect.sh 适当调整 JVM Parameters Configuration
+
+**tips**: The JVM Parameters Configuration can be adjusted in /bin/runconnect.sh as needed.
>JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"
-runtime启动成功：
+runtime start successful：
>The standalone worker boot success.
-查看启动日志文件：
+View the startup log files.
>tail -100f ~/logs/rocketmqconnect/connect_runtime.log
-ctrl + c 退出日志
+`ctrl + c` exit log
-## 4.启动source connector
+## 4. Start source connector
+
+Create a test file named test-source-file.txt in the current directory.
-当前目录创建测试文件 test-source-file.txt
```
touch test-source-file.txt
@@ -69,22 +69,22 @@ echo "Hello \r\nRocketMQ\r\n Connect" >> test-source-file.txt
curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/fileSourceConnector -d '{"connector.class":"org.apache.rocketmq.connect.file.FileSourceConnector","filename":"test-source-file.txt","connect.topicname":"fileTopic"}'
```
-看到以下日志说明 file source connector 启动成功了
+If you see the following log message, it means the file source connector has started successfully.
>tail -100f ~/logs/rocketmqconnect/connect_runtime.log
>
>2019-07-16 11:18:39 INFO pool-7-thread-1 - **Source task start**, config:{"properties":{"source-record-...
-#### source connector配置说明
+#### source connector configuration instructions
-| key | nullable | default | description |
-|-------------------| -------- | ---------------------|--------------------------|
-| connector.class | false | | 实现 Connector接口的类名称（包含包名） |
-| filename | false | | 数据源文件名称 |
-| connect.topicname | false | | 同步文件数据所需topic |
+| key | nullable | default | description |
+| ----------------- | -------- | ------- | ------------------------------------------------------------ |
+| connector.class | false | | The class name (including the package name) that implements the Connector interface |
+| filename | false | | source file name |
+| connect.topicname | false | | Topic required for synchronizing file data |
-## 5.启动sink connector
+## 5. Start sink connector
```
curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/fileSinkConnector -d '{"connector.class":"org.apache.rocketmq.connect.file.FileSinkConnector","filename":"test-sink-file.txt","connect.topicnames":"fileTopic"}'
@@ -95,68 +95,70 @@ cat test-sink-file.txt
> tail -100f ~/logs/rocketmqconnect/connect_runtime.log
-看到以下日志说明file sink connector 启动成功了
+If you see the following log message, it means the file sink connector has started successfully.
> 2019-07-16 11:24:58 INFO pool-7-thread-2 - **Sink task start**, config:{"properties":{"source-record-...
-如果 test-sink-file.txt 生成并且与 source-file.txt 内容一样，说明整个流程正常运行。
-文件内容可能顺序不一样，这主要是因为RocketMQ发到不同queue时，接收不同queue消息顺序可能也不一致导致的，是正常的。
+If test-sink-file.txt is generated and its content is the same as source-file.txt, it means that the entire process is running normally.
+
+The file contents may be in a different order, which is normal because the order of messages received from different queues in RocketMQ may also be inconsistent.
-#### sink connector配置说明
+#### sink connector configuration instructions
-| key | nullable | default | description |
-|--------------------| -------- | ------- | -------------------------------------------------------------------------------------- |
-| connector.class | false | | 实现Connector接口的类名称（包含包名） |
-| filename | false | | sink拉去的数据保存到文件 |
-| connect.topicnames | false | | sink需要处理数据消息topics |
+| key | nullable | default | description |
+| ------------------ | -------- | ------- | ------------------------------------------------------------ |
+| connector.class | false | | The class name (including the package name) that implements the Connector interface |
+| filename | false | | The sink pulls data and saves it to a file. |
+| connect.topicnames | false | | The topics of the data messages that the sink needs to process. |
```
-注：source/sink配置文件说明是以rocketmq-connect-sample为demo，不同source/sink connector配置有差异，请以具体sourc/sink connector 为准
+Tips:The configuration file instructions for the sample rocketmq-connect-sample are for reference only, different source/sink connectors have different configurations, please refer to the specific source/sink connector.
```
-## 6.停止connector
+## 6. Stop connector
```shell
-GET请求
+#GET request
http://(your worker ip):(port)/connectors/(connector name)/stop
-停止demo中的两个connector
+#Stopping the two connectors in the demo
curl http://127.0.0.1:8082/connectors/fileSinkConnector/stop
curl http://127.0.0.1:8082/connectors/fileSourceConnector/stop
```
-看到以下日志说明connector停止成功了
+
+Seeing the following log message indicates that the connector has been successfully stopped.
>**Source task stop**, config:{"properties":{"source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter","filename":"/home/zhoubo/IdeaProjects/my-new3-rocketmq-externals/rocketmq-connect/rocketmq-connect-runtime/source-file.txt","task-class":"org.apache.rocketmq.connect.file.FileSourceTask","topic":"fileTopic","connector-class":"org.apache.rocketmq.connect.file.FileSourceConnector","update-timestamp":"1564765189322"}}
-## 7.停止Worker进程
+## 7. Stopping the Worker process
```
sh bin/connectshutdown.sh
```
-## 8.日志目录
+## 8. Log directory
>${user.home}/logs/rocketmqconnect
-## 9.配置文件
+## 9. Configuration file
-持久化配置文件默认目录 /tmp/storeRoot
+The default directory for persistent configuration files is /tmp/storeRoot.
-| key | description |
-|----------------------|---------------------------|
-| connectorConfig.json | connector配置持久化文件 |
-| position.json | source connect数据处理进度持久化文件 |
-| taskConfig.json | task配置持久化文件 |
-| offset.json | sink connect数据消费进度持久化文件 |
-| connectorStatus.json | connector 状态持久化文件 |
-| taskStatus.json | task 状态持久化文件 |
+| key | description |
+| -------------------- | --------------------------------------------------------- |
+| connectorConfig.json | Connector configuration persistence files |
+| position.json | Source connect data processing progress persistence files |
+| taskConfig.json | Task configuration persistence files |
+| offset.json | Sink connect data consumption progress persistence files |
+| connectorStatus.json | Connector status persistence files |
+| taskStatus.json | Task status persistence files |
-## 10.配置说明
+## 10. Configuration Instructions
-可根据使用情况修改 [RESTful](https://restfulapi.cn/) 端口，storeRoot 路径，Nameserver 地址等信息
+Modify the RESTful port, storeRoot path, Nameserver address, and other information based on your usage.
-文件位置：work 启动目录下 conf/connect-standalone.conf
+The file location is in the conf/connect-standalone.conf under the work startup directory.
```shell
#current cluster node uniquely identifies
@@ -168,15 +170,14 @@ httpPort=8082
# Local file dir for config store
storePathRootDir=/home/connect/storeRoot
-#需要修改为自己的rocketmq nameserver 接入点
+#You need to modify it to your own rocketmq nameserver endpoint.
# RocketMQ namesrvAddr
namesrvAddr=127.0.0.1:9876
-#用于加载Connector插件，类似于jvm启动加载jar包或者class类，这里目录目录用于放Connector相关的实现插件，
-支持文件和目录
+#This is used for loading Connector plugins, similar to how JVM loads jar packages or classes at startup. This directory is used for placing Connector-related implementation plugins and supports both files and directories.
# Source or sink connector jar file dir
pluginPaths=rocketmq-connect-sample/target/rocketmq-connect-sample-0.0.1-SNAPSHOT.jar
-# 补充：将 Connector 相关实现插件保存到指定文件夹
+# Addition : put the Connector-related implementation plugins in the specified folder.
# pluginPaths=/usr/local/connector-plugins/*
```
\ No newline at end of file