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 482a6eb..66335a7 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
@@ -3,6 +3,7 @@ package com.lanyuanxiaoyao.service.monitor.metric;
 import cn.hutool.core.util.StrUtil;
 import com.lanyuanxiaoyao.service.common.Constants;
 import com.lanyuanxiaoyao.service.common.utils.NameHelper;
+import com.lanyuanxiaoyao.service.configuration.ExecutorProvider;
 import com.lanyuanxiaoyao.service.configuration.HudiServiceProperties;
 import com.lanyuanxiaoyao.service.forest.service.InfoService;
 import com.lanyuanxiaoyao.service.forest.service.PulsarService;
@@ -17,7 +18,6 @@ import org.slf4j.LoggerFactory;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
-import static com.lanyuanxiaoyao.service.common.Constants.HALF_HOUR;
 import static com.lanyuanxiaoyao.service.common.Constants.MINUTE;
 
 /**
@@ -47,11 +47,11 @@ public class PulsarMetrics extends Metrics {
         backlogMap = Maps.mutable.empty();
     }
 
-    @Scheduled(fixedDelay = HALF_HOUR, initialDelay = MINUTE)
+    @Scheduled(fixedDelay = 10 * MINUTE, initialDelay = MINUTE)
     @Override
     void update() {
         infoService.tableMetaList()
-                // .asParallel(ExecutorProvider.EXECUTORS, 50)
+                .asParallel(ExecutorProvider.EXECUTORS, 2)
                 .reject(meta -> StrUtil.isBlank(meta.getPulsarAddress()))
                 .forEach(meta -> {
                     try {
@@ -74,7 +74,8 @@ public class PulsarMetrics extends Metrics {
                             backlogCache.set(backlog);
                             infoService.savePulsarBacklog(meta.getJob().getId(), meta.getAlias(), backlog);
                         }
-                    } catch (Exception ignored) {
+                    } catch (Exception exception) {
+                        logger.warn("Update pulsar backlog fail for " + meta.getAlias(), exception);
                     }
                 });
     }