From 3fa768f35a6c85aaa0268b7f3a7ae471f713731e Mon Sep 17 00:00:00 2001
From: ping <1017253325@qq.com>
Date: Thu, 20 Nov 2025 15:17:11 +0800
Subject: [PATCH] update

---
 b/baiduc/baidu_sms_kafka_consumer.dspy | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/b/baiduc/baidu_sms_kafka_consumer.dspy b/b/baiduc/baidu_sms_kafka_consumer.dspy
index a03b978..7729cbc 100644
--- a/b/baiduc/baidu_sms_kafka_consumer.dspy
+++ b/b/baiduc/baidu_sms_kafka_consumer.dspy
@@ -39,13 +39,13 @@ async def baidu_sms_kafka_consumer(ns={}):
             pass
     
     total_count = 0
-    for i in range(30):
+    for i in range(2):
         if i == 0:
             # 写入文件记录轮询开始时间 时间格式: YYYY-MM-DD HH:MM:SS
             with open('baidu_kafka_msg.txt', 'a', encoding='utf-8') as f:
                 f.write(f"轮询开始时间：{datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n")
         
-        msg = consumer.poll(0.1)  # 单次轮询获取消息
+        msg = consumer.poll(0.2)  # 单次轮询获取消息
 
         if msg is None:
             if i == 10: