From e94478265bb8176b2378bceca9ce101c871b22c8 Mon Sep 17 00:00:00 2001
From: yfh <yuan.fenghua@free-sun.com.cn>
Date: Mon, 24 Feb 2025 23:51:54 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0performance=E7=9B=B8=E5=85=B3?=
 =?UTF-8?q?=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config.yaml | 43 +++++++++++++++++++++++++++++++++++++------
 1 file changed, 37 insertions(+), 6 deletions(-)

diff --git a/config.yaml b/config.yaml
index d6e7ceb..d3d929d 100644
--- a/config.yaml
+++ b/config.yaml
@@ -1,13 +1,43 @@
 pprof:
   enable: false
+performance:
+  target:
+    throughput: 5000 # 吞吐量
+  master:
+    rpc:
+      concurrency: 50 # 并发请求数
+    kafkaConsumer:
+      consumerCfg:
+        minFetch: 10240 # 最小拉取大小 Byte。10*1024=10KB
+        maxFetch: 5242880 # 最大拉取大小 Byte。5*1024*1024=5MB,注意不要超过 int32 最大值
+        maxWaitTime: 300 # 一次拉取最大等待时间 ms。建议在 250-500 之间
+      data_raw:
+        maxBatchSize: 51200 # 批量处理的最大小 Byte。50*1024=50KB
+        iotaBufSize: 500 # IOTA 通道的缓冲区大小
+        processBufSize: 200 # Process 通道的缓冲区大小
+      data_agg:
+        maxBatchSize: 10240 # 批量处理的最大小 Byte。10*1024=10KB
+        aggBufSize: 300 # agg 通道的缓冲区大小
+  node:
+    stageTimeout: 60 # stage 处理超时时间 秒
+    stageBufSize: 1 # stage in/out 通道的缓冲区大小
+    iotaWorkerCount: 5 # IOTA 工作线程数。iotaData -> deviceData
+    iotaBufSize: 1 # IOTA 通道的缓冲区大小
+    processSendTimeout: 60 # processChannels 发送的超时时间 秒。
+    processBufSize: 1 # processChannels 通道的缓冲区大小
+    stageResultBufSize: 500 # stage 处理结果通道的缓冲区大小
 kafka:
-  groupId: local_et_go2
+  groupId: local_et_go0102
   brokers:
     - 10.8.30.142:30992
   topics:
-#    data_theme: native_theme
-    data_raw: RawData
-#    data_agg: native_agg
+    data_raw:
+      topic: RawData12
+      partitions: 4
+    data_agg:
+      topic: native_agg
+      partitions: 1
+    data_theme: native_theme
     alarm_iota: Alert
     alarm_anxinyun: native_alarm
 redis:
@@ -16,7 +46,7 @@ es:
   enable: true
   addresses:
     - http://10.8.30.142:30092
-#    - http://10.8.30.160:30092
+  #    - http://10.8.30.160:30092
   user: ""
   pwd: ""
   index:
@@ -39,6 +69,7 @@ prometheus:
 
 #测点数据推送
 push:
+  enable: false
   mqtt:
     enable: false
     host: 10.8.30.142
@@ -52,7 +83,7 @@ push:
 #    节点信息        #
 master:
   port: 50000
-  hostNameTag: "0"  #多状态副本 master 节点的 hostName 标记 DESKTOP-1QK809D
+  hostNameTag: "node-client"  #多状态副本 master 节点的 hostName 标记 DESKTOP-1QK809D
 node:
   remoteMasterHost: 10.8.30.104   #用于 node Register -> master
   hostIpPrefix: 10.8.    #多网卡筛选ip网段