From a4710845d76678b33ed5a269f155d7b73deefb34 Mon Sep 17 00:00:00 2001
From: v-zhangjc9 <v-zhangjc9.gd@chinatelecom.cn>
Date: Wed, 22 May 2024 13:08:50 +0800
Subject: [PATCH] =?UTF-8?q?perf(monitor):=20=E4=BC=98=E5=8C=96pulsar=20bac?=
 =?UTF-8?q?klog=E8=AF=BB=E5=8F=96=E7=9A=84=E5=8E=8B=E5=8A=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../lanyuanxiaoyao/service/monitor/metric/PulsarMetrics.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/metric/PulsarMetrics.java b/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/metric/PulsarMetrics.java
index 873776c..47329bf 100644
--- a/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/metric/PulsarMetrics.java
+++ b/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/metric/PulsarMetrics.java
@@ -51,7 +51,7 @@ public class PulsarMetrics extends Metrics {
     @Override
     void update() {
         infoService.tableMetaList()
-                .asParallel(ExecutorProvider.EXECUTORS, 2)
+                .asParallel(ExecutorProvider.EXECUTORS_2, 1)
                 .reject(meta -> StrUtil.isBlank(meta.getPulsarAddress()))
                 .forEach(meta -> {
                     try {