diff --git a/b/baiduc/baidu_sms_kafka_consumer.dspy b/b/baiduc/baidu_sms_kafka_consumer.dspy
index ded0283..c63ba97 100644
--- a/b/baiduc/baidu_sms_kafka_consumer.dspy
+++ b/b/baiduc/baidu_sms_kafka_consumer.dspy
@@ -39,7 +39,7 @@ async def baidu_sms_kafka_consumer(ns={}):
             pass
     
     total_count = 0
-    for i in range(2):
+    for i in range(20):
         # if i == 0:
         #     # 写入文件记录轮询开始时间 时间格式: YYYY-MM-DD HH:MM:SS
         #     with open('baidu_kafka_msg.txt', 'a', encoding='utf-8') as f:
diff --git a/kgadget/src/more_task_scheduler.py b/kgadget/src/more_task_scheduler.py
index 76cd24f..c41fd81 100644
--- a/kgadget/src/more_task_scheduler.py
+++ b/kgadget/src/more_task_scheduler.py
@@ -183,7 +183,7 @@ def setup_scheduler():
     scheduler.add_job(
         task_executor.get_baidu_kafka_info,
         'interval',
-        seconds=5,
+        seconds=6,
         id='get_baidu_kafka_info_job',
         replace_existing=True
     )