aloyszhang commented on code in PR #1127:
URL: https://github.com/apache/inlong-website/pull/1127#discussion_r1975286649


##########
i18n/zh-CN/docusaurus-plugin-content-docs/current/modules/sort-standalone/pulsar2es.md:
##########
@@ -0,0 +1,205 @@
+---
+title: Pulsar 到 Elasticsearch 示例
+sidebar_position: 4
+---
+## 准备安装文件
+安装文件在`inlong-sort-standalone/sort-standalone-dist/target/`目录下,文件名是`apache-inlong-sort-standalone-${project.version}-bin.tar.gz`。
+
+## 准备修改配置文件
+首先,解压压缩包`apache-inlong-sort-standalone-${project.version}-bin.tar.gz`,然后从目录`conf/es/`下拷贝3个文件到目录`conf/`。
+
+- conf/common.properties,所有组件的基本配置参数。
+- conf/SortClusterConfig.conf,所有Sort任务的sink配置。, sink configuration of all sort 
tasks.
+- 
conf/sid_es_v3.conf,一个Sort任务的数据源配置,文件名和配置文件SortClusterConfig.conf中的Sort任务名一致,如果SortClusterConfig.conf中配置了多个Sort任务,那么会有多个Sort任务的数据源配置。
+
+### conf/common.properties 配置样例
+
+```properties
+# inlong-sort-standalone集群唯一标识
+clusterId=esv3-sz-sz1
+# 当前节点ID
+nodeId=nodeId
+# 指标汇总域名
+metricDomains=Sort
+# 指标汇总监听器类名列表,空格分隔
+metricDomains.Sort.domainListeners=org.apache.inlong.sort.standalone.metrics.prometheus.PrometheusMetricListener
+# 订阅tube的重试超时时间,单位为ms
+metricDomains.Sort.snapshotInterval=60000
+# Channel类型
+sortChannel.type=org.apache.inlong.sort.standalone.channel.BufferQueueChannel
+# Sink类名,不同的分发类型使用不同的Sink类
+sortSink.type=org.apache.inlong.sort.standalone.sink.elasticsearch.EsSink
+# Source类名
+sortSource.type=org.apache.inlong.sort.standalone.source.sortsdk.SortSdkSource
+# 集群配置数据的加载来源,有三种方式:[文件,Manager,自定义类]。
+sortClusterConfig.type=file
+# 当集群配置数据加载来源是file时,在类路径下的配置文件名
+sortClusterConfig.file=SortClusterConfig.conf
+# Sort任务配置数据的加载来源,有三种方式:[文件,Manager,自定义类]
+sortSourceConfig.QueryConsumeConfigType=file
+```
+
+### conf/SortClusterConfig.conf 配置样例
+
+```json
+{
+  "clusterName": "esv3-gz-gz1",
+  "sortTasks": [
+    {
+      "name": "sid_es_v3",
+      "type": "ES",
+      "idParams": [
+        {
+          "indexNamePattern": "inlong0fc00000046_{yyyyMMdd}",
+          "contentOffset": "0",
+          "inlongGroupId": "atta",
+          "fieldOffset": "2",
+          "fieldNames": "ftime extinfo t1 t2 t3 t4",
+          "inlongStreamId": "0fc00000046",
+          "separator": "|"
+        }
+      ],
+      "sinkParams": {
+        "httpHosts": "11.187.135.221:9200",
+        "password": "yingyan@ES",
+        "auditSetName": "es-rmrv7g7a",
+        "bulkSizeMb": "10",
+        "flushInterval": "60",
+        "keywordMaxLength": "32767",
+        "bulkAction": "4000",
+        "concurrentRequests": "5",
+        "maxConnect": "10",
+        "isUseIndexId": "false",
+        "username": "elastic"
+      }
+    }
+  ]
+}
+```
+
+### conf/sid_es_v3.conf 配置样例
+
+```json
+{
+  "sortClusterName": "esv3-gz-gz1",
+  "sortTaskId": "sid_es_v3",
+  "cacheZones": {
+    "pc_atta6th_sz1": {
+      "zoneName": "pc_atta6th_sz1",
+      "serviceUrl": "http://9.139.53.86:8080";,
+      "authentication": 
"eyJrZXlJZCI6InB1bHNhci04MnhhN24zZWs1ZHciLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJwdWxzYXItODJ4YTduM2VrNWR3X2FkbWluIn0.D5H_j8UQk8KYWHw_mzq2HmR393SnbL5Gz7JYCANBPnI",
+      "topics": [
+        {
+          "topic": "pulsar-82xa7n3ek5dw/atta/atta_topic_1",
+          "partitionCnt": 10,
+          "topicProperties": {}
+        }
+      ],
+      "cacheZoneProperties": {},
+      "zoneType": "pulsar"
+    }
+  }
+}
+```
+
+## conf/common.properties 配置参数
+
+| 参数名                                     | 是否必须 | 默认值                         
                                                  | 描述                          
                                                                                
                             |
+|-----------------------------------------|------|-------------------------------------------------------------------------------|------------------------------------------------------------------------------------------------------------------------------------------|
+| clusterId                               | Y    | NA                          
                                                  | 
用来唯一标识一个inlong-sort-standalone集群                                                
                                                         |
+| nodeId                                  | N    | 本机IP                        
                                                  | 当前节点ID                      
                                                                                
                             |
+| metricDomains                           | N    | Sort                        
                                                  | 指标汇总域名                      
                                                                                
                             |
+| metricDomains.Sort.domainListeners      | N    | 
org.apache.inlong.sort.standalone.metrics.prometheus.PrometheusMetricListener | 
指标汇总监听器类名列表,空格分隔                                                                
                                                         |
+| metricDomains.Sort.snapshotInterval     | N    | 60000                       
                                                  | 订阅tube的重试超时时间,单位为ms         
                                                                                
                             |
+| prometheusHttpPort                      | N    | 8080                        
                                                  | 
org.apache.inlong.sort.standalone.metrics.prometheus.PrometheusMetricListener的参数,Prometheus的HttpServer端口
                                 |
+| sortChannel.type                        | N    | 
org.apache.inlong.sort.standalone.channel.BufferQueueChannel                  | 
Channel类型                                                                       
                                                         |
+| sortSink.type                           | Y    | NA                          
                                                  | Sink类名,不同的分发类型使用不同的Sink类    
                                                                                
                             |
+| sortSource.type                         | N    | 
org.apache.inlong.sort.standalone.source.sortsdk.SortSdkSource                | 
Source类名                                                                        
                                                         |
+| sortClusterConfig.type                  | N    | manager                     
                                                  | 
集群配置数据的加载来源,有三种方式:[文件,Manager,自定义类]。                                            
                                                         |
+| sortClusterConfig.file                  | N    | SortClusterConfig.conf      
                                                  | 
当集群配置数据加载来源是file时,在类路径下的配置文件名                                                   
                                                         |
+| sortClusterConfig.managerUrl            | N    | NA                          
                                                  | 
集群配置数据加载来源是manager时,这里定义InlongManager的URL<br/>比如:http://${manager 
ip:port}/api/inlong/manager/openapi/sort/standalone/getClusterConfig   |
+| sortSourceConfig.QueryConsumeConfigType | N    | manager                     
                                                  | 
Sort任务配置数据的加载来源,有三种方式:[文件,Manager,自定义类]。 
<br/>如果加载路径是file的话,Sort任务配置文件是在类路径里,文件名的格式:${sortTaskId}.conf。                  
                |
+| sortSourceConfig.managerUrl             | N    | NA                          
                                                  | 
Sort任务配置数据加载来源是manager时,这里定义InlongManager的URL<br/>比如::http://${manager 
ip:port}/api/inlong/manager/openapi/sort/standalone/getSortSource |
+
+## SortClusterConfig.conf 配置参数
+
+- 可以从ClassPath的SortClusterConfig.conf源文件读取,但不支持实时更新
+- 可以从Inlong Manager的HTTP接口获取配置,支持实时更新

Review Comment:
   ```suggestion
   - 可以从ClassPath的SortClusterConfig.conf源文件读取,但不支持实时更新。
   - 可以从Inlong Manager的HTTP接口获取配置,支持实时更新。
   ```



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to