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 {