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 2022/12/27 10:42:11 UTC
[rocketmq-site] branch new-official-website updated: [ISSUE #388] Add doc for using Elasticsearch Connector (#389)
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 893549b5b [ISSUE #388] Add doc for using Elasticsearch Connector (#389)
893549b5b is described below
commit 893549b5b4495cf62bd0c9a5980470c860030e15
Author: Oliver <wq...@163.com>
AuthorDate: Tue Dec 27 18:42:06 2022 +0800
[ISSUE #388] Add doc for using Elasticsearch Connector (#389)
---
.../32RocketMQ Connect In Action5-ES.md" | 159 +++++++++++++++++++++
.../32RocketMQ Connect In Action5-ES.md" | 157 ++++++++++++++++++++
.../32RocketMQ Connect In Action5-ES.md" | 157 ++++++++++++++++++++
.../32RocketMQ Connect In Action5-ES.md" | 159 +++++++++++++++++++++
4 files changed, 632 insertions(+)
diff --git "a/docs/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md" "b/docs/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
new file mode 100644
index 000000000..783d8bf13
--- /dev/null
+++ "b/docs/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
@@ -0,0 +1,159 @@
+# RocketMQ Connect实战5
+
+Elsticsearch Source - >RocketMQ Connect -> Elasticsearch Sink
+
+## 准备
+
+### 启动RocketMQ
+
+1. Linux/Unix/Mac
+2. 64bit JDK 1.8+;
+3. Maven 3.2.x或以上版本;
+4. 启动 [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+
+
+
+**tips** : ${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插件编译
+
+Elasticsearch RocketMQ Connector
+```
+$ cd rocketmq-connect/connectors/rocketmq-connect-elasticsearch/
+$ mvn clean package -Dmaven.test.skip=true
+```
+
+将 Elasticsearch RocketMQ Connector 编译好的包放入Runtime加载目录。命令如下：
+```
+mkdir -p /usr/local/connector-plugins
+cp rocketmq-connect-elasticsearch/target/rocketmq-connect-elasticsearch-1.0.0-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"
+
+# 核心配置，将之前编译好elasticsearch包的插件目录配置在此；
+# 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 &
+
+```
+
+### Elasticsearch镜像
+
+使用 docker 搭建环境 Elasticsearch 数据库
+```
+# starting a elasticsearch instance
+docker run --name my-elasticsearch -p 9200:9200 -p 9300:9300 -e "ES_JAVA_OPTS=-Xms1g -Xmx1g" -d 74c2e0ec249c
+```
+### Kibana镜像
+
+使用 docker 搭建环境 Kibana
+```
+docker run --name my-kibana -e ELASTICSEARCH_URL=http://192.168.0.101:9200 -p 5601:5601 -d 5dca66b41943
+```
+
+
+### 测试数据
+
+通过 kibana Dev Tools 创建测试数据：参考 [console-ibana](https://www.elastic.co/guide/en/kibana/8.5/console-kibana.html#console-kibana);
+
+
+源索引：connect_es
+
+## 启动Connector
+
+### 启动Elasticsearch source connector
+
+同步源索引数据：connect_es
+作用：通过解析 Elasticsearch 文档数据封装成通用的ConnectRecord对象，发送的RocketMQ Topic当中
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/elasticsearchSourceConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSourceConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9200,
+ "index":{
+ "connect_es": {
+ "primaryShards":1,
+ "id":1
+ }
+ },
+ "max.tasks":2,
+ "connect.topicname":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+```
+
+### 启动 Elasticsearch sink connector
+
+作用：通过消费Topic中的数据，写入到目标索引当中
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/ElasticsearchSinkConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSinkConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9202,
+ "max.tasks":2,
+ "connect.topicnames":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+
+```
+
+note：本地测试需要启动两个不同端口的Elasticsearch进程
+
+以上两个Connector任务创建成功以后
+通过访问sink指定的Elasticsearch是否包含数据
+
+对源索引的新增数据
+即可同步到目标索引当中
+
+
diff --git "a/i18n/en/docusaurus-plugin-content-docs/current/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md" "b/i18n/en/docusaurus-plugin-content-docs/current/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
new file mode 100644
index 000000000..48a8f14ef
--- /dev/null
+++ "b/i18n/en/docusaurus-plugin-content-docs/current/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
@@ -0,0 +1,157 @@
+# RocketMQ Connect actual combat 5
+
+Elsticsearch Source - >RocketMQ Connect -> Elasticsearch Sink
+
+## preparatory work
+
+### Start RocketMQ
+
+1. Linux/Unix/Mac
+2. 64bit JDK 1.8+;
+3. Maven 3.2.x or later;
+4. Start [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+
+
+
+**tips** : ${ROCKETMQ_HOME} Position Description
+
+>bin-release.zip version：/rocketmq-all-4.9.4-bin-release
+>
+>source-release.zip versioon：/rocketmq-all-4.9.4-source-release/distribution
+
+
+### Start Connect
+
+
+#### Connector plugin compilation
+
+Elasticsearch RocketMQ Connector
+```
+$ cd rocketmq-connect/connectors/rocketmq-connect-elasticsearch/
+$ mvn clean package -Dmaven.test.skip=true
+```
+
+Put the compiled Elasticsearch RocketMQ Connector package into the Runtime load directory. The command is as follows:
+```
+mkdir -p /usr/local/connector-plugins
+cp rocketmq-connect-elasticsearch/target/rocketmq-connect-elasticsearch-1.0.0-jar-with-dependencies.jar /usr/local/connector-plugins
+```
+
+
+#### Start Connect Runtime
+
+```
+cd rocketmq-connect
+
+mvn -Prelease-connect -DskipTests clean install -U
+
+```
+
+Update `connect-standalone.conf` ，Key configurations are 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 where the plugin directory where you compiled the elasticsearch package is located
+# 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 &
+
+```
+
+### Elasticsearch Image
+
+Use docker to build the Elasticsearch database
+```
+# starting a elasticsearch instance
+docker run --name my-elasticsearch -p 9200:9200 -p 9300:9300 -e "ES_JAVA_OPTS=-Xms1g -Xmx1g" -d 74c2e0ec249c
+```
+### Kibana Image
+
+Use docker to build the Kibana environment
+```
+docker run --name my-kibana -e ELASTICSEARCH_URL=http://192.168.0.101:9200 -p 5601:5601 -d 5dca66b41943
+```
+
+
+### test data
+
+Create test data with kibana Dev Tools: reference [console-ibana](https://www.elastic.co/guide/en/kibana/8.5/console-kibana.html#console-kibana);
+
+
+Source Index：connect_es
+
+## Start Connector
+
+### Start Elasticsearch source connector
+
+Synchronizing source index data: connect_es
+effect：Send a RocketMQ Topic by parsing Elasticsearch document data and wrapping it into a generic ConnectRecord object
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/elasticsearchSourceConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSourceConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9200,
+ "index":{
+ "connect_es": {
+ "primaryShards":1,
+ "id":1
+ }
+ },
+ "max.tasks":2,
+ "connect.topicname":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+```
+
+### Start Elasticsearch sink connector
+
+effect：Data is written to the target index by consuming the Topic
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/ElasticsearchSinkConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSinkConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9202,
+ "max.tasks":2,
+ "connect.topicnames":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+
+```
+
+note：Local testing requires you to start the Elasticsearch process on two different ports
+
+After the two Connector tasks are successfully created Whether the Elasticsearch specified by accessing sink contains data
+
+New data added to the source index can be synchronized to the target index
+
+
diff --git "a/i18n/en/docusaurus-plugin-content-docs/version-5.0/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md" "b/i18n/en/docusaurus-plugin-content-docs/version-5.0/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
new file mode 100644
index 000000000..48a8f14ef
--- /dev/null
+++ "b/i18n/en/docusaurus-plugin-content-docs/version-5.0/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
@@ -0,0 +1,157 @@
+# RocketMQ Connect actual combat 5
+
+Elsticsearch Source - >RocketMQ Connect -> Elasticsearch Sink
+
+## preparatory work
+
+### Start RocketMQ
+
+1. Linux/Unix/Mac
+2. 64bit JDK 1.8+;
+3. Maven 3.2.x or later;
+4. Start [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+
+
+
+**tips** : ${ROCKETMQ_HOME} Position Description
+
+>bin-release.zip version：/rocketmq-all-4.9.4-bin-release
+>
+>source-release.zip versioon：/rocketmq-all-4.9.4-source-release/distribution
+
+
+### Start Connect
+
+
+#### Connector plugin compilation
+
+Elasticsearch RocketMQ Connector
+```
+$ cd rocketmq-connect/connectors/rocketmq-connect-elasticsearch/
+$ mvn clean package -Dmaven.test.skip=true
+```
+
+Put the compiled Elasticsearch RocketMQ Connector package into the Runtime load directory. The command is as follows:
+```
+mkdir -p /usr/local/connector-plugins
+cp rocketmq-connect-elasticsearch/target/rocketmq-connect-elasticsearch-1.0.0-jar-with-dependencies.jar /usr/local/connector-plugins
+```
+
+
+#### Start Connect Runtime
+
+```
+cd rocketmq-connect
+
+mvn -Prelease-connect -DskipTests clean install -U
+
+```
+
+Update `connect-standalone.conf` ，Key configurations are 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 where the plugin directory where you compiled the elasticsearch package is located
+# 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 &
+
+```
+
+### Elasticsearch Image
+
+Use docker to build the Elasticsearch database
+```
+# starting a elasticsearch instance
+docker run --name my-elasticsearch -p 9200:9200 -p 9300:9300 -e "ES_JAVA_OPTS=-Xms1g -Xmx1g" -d 74c2e0ec249c
+```
+### Kibana Image
+
+Use docker to build the Kibana environment
+```
+docker run --name my-kibana -e ELASTICSEARCH_URL=http://192.168.0.101:9200 -p 5601:5601 -d 5dca66b41943
+```
+
+
+### test data
+
+Create test data with kibana Dev Tools: reference [console-ibana](https://www.elastic.co/guide/en/kibana/8.5/console-kibana.html#console-kibana);
+
+
+Source Index：connect_es
+
+## Start Connector
+
+### Start Elasticsearch source connector
+
+Synchronizing source index data: connect_es
+effect：Send a RocketMQ Topic by parsing Elasticsearch document data and wrapping it into a generic ConnectRecord object
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/elasticsearchSourceConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSourceConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9200,
+ "index":{
+ "connect_es": {
+ "primaryShards":1,
+ "id":1
+ }
+ },
+ "max.tasks":2,
+ "connect.topicname":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+```
+
+### Start Elasticsearch sink connector
+
+effect：Data is written to the target index by consuming the Topic
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/ElasticsearchSinkConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSinkConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9202,
+ "max.tasks":2,
+ "connect.topicnames":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+
+```
+
+note：Local testing requires you to start the Elasticsearch process on two different ports
+
+After the two Connector tasks are successfully created Whether the Elasticsearch specified by accessing sink contains data
+
+New data added to the source index can be synchronized to the target index
+
+
diff --git "a/versioned_docs/version-5.0/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md" "b/versioned_docs/version-5.0/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
new file mode 100644
index 000000000..783d8bf13
--- /dev/null
+++ "b/versioned_docs/version-5.0/07-\346\225\260\346\215\256\351\233\206\346\210\220/32RocketMQ Connect In Action5-ES.md"
@@ -0,0 +1,159 @@
+# RocketMQ Connect实战5
+
+Elsticsearch Source - >RocketMQ Connect -> Elasticsearch Sink
+
+## 准备
+
+### 启动RocketMQ
+
+1. Linux/Unix/Mac
+2. 64bit JDK 1.8+;
+3. Maven 3.2.x或以上版本;
+4. 启动 [RocketMQ](https://rocketmq.apache.org/docs/quick-start/);
+
+
+
+**tips** : ${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插件编译
+
+Elasticsearch RocketMQ Connector
+```
+$ cd rocketmq-connect/connectors/rocketmq-connect-elasticsearch/
+$ mvn clean package -Dmaven.test.skip=true
+```
+
+将 Elasticsearch RocketMQ Connector 编译好的包放入Runtime加载目录。命令如下：
+```
+mkdir -p /usr/local/connector-plugins
+cp rocketmq-connect-elasticsearch/target/rocketmq-connect-elasticsearch-1.0.0-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"
+
+# 核心配置，将之前编译好elasticsearch包的插件目录配置在此；
+# 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 &
+
+```
+
+### Elasticsearch镜像
+
+使用 docker 搭建环境 Elasticsearch 数据库
+```
+# starting a elasticsearch instance
+docker run --name my-elasticsearch -p 9200:9200 -p 9300:9300 -e "ES_JAVA_OPTS=-Xms1g -Xmx1g" -d 74c2e0ec249c
+```
+### Kibana镜像
+
+使用 docker 搭建环境 Kibana
+```
+docker run --name my-kibana -e ELASTICSEARCH_URL=http://192.168.0.101:9200 -p 5601:5601 -d 5dca66b41943
+```
+
+
+### 测试数据
+
+通过 kibana Dev Tools 创建测试数据：参考 [console-ibana](https://www.elastic.co/guide/en/kibana/8.5/console-kibana.html#console-kibana);
+
+
+源索引：connect_es
+
+## 启动Connector
+
+### 启动Elasticsearch source connector
+
+同步源索引数据：connect_es
+作用：通过解析 Elasticsearch 文档数据封装成通用的ConnectRecord对象，发送的RocketMQ Topic当中
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/elasticsearchSourceConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSourceConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9200,
+ "index":{
+ "connect_es": {
+ "primaryShards":1,
+ "id":1
+ }
+ },
+ "max.tasks":2,
+ "connect.topicname":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+```
+
+### 启动 Elasticsearch sink connector
+
+作用：通过消费Topic中的数据，写入到目标索引当中
+
+```
+curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/ElasticsearchSinkConnector -d '{
+ "connector.class":"org.apache.rocketmq.connect.elasticsearch.connector.ElasticsearchSinkConnector",
+ "elasticsearchHost":"localhost",
+ "elasticsearchPort":9202,
+ "max.tasks":2,
+ "connect.topicnames":"ConnectEsTopic",
+ "value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
+ "key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
+}'
+
+```
+
+note：本地测试需要启动两个不同端口的Elasticsearch进程
+
+以上两个Connector任务创建成功以后
+通过访问sink指定的Elasticsearch是否包含数据
+
+对源索引的新增数据
+即可同步到目标索引当中
+
+