From 104a5b4bc5c319c5bb4a4bcba863a012d4f5efbd Mon Sep 17 00:00:00 2001
From: ping <1017253325@qq.com>
Date: Fri, 21 Nov 2025 17:21:02 +0800
Subject: [PATCH] updsate

---
 kgadget/src/baidu_sms_kafka_consumer.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/kgadget/src/baidu_sms_kafka_consumer.py b/kgadget/src/baidu_sms_kafka_consumer.py
index 8434f5d..d247015 100644
--- a/kgadget/src/baidu_sms_kafka_consumer.py
+++ b/kgadget/src/baidu_sms_kafka_consumer.py
@@ -124,7 +124,7 @@ async def baidu_sms_kafka_consumer(ns={}):
     # 订阅的主题名称
     consumer.subscribe(['kaiyuanyun_msg_topic'])
     while True:
-        msg = consumer.poll(2)  # 单次轮询获取消息
+        msg = consumer.poll(1)  # 单次轮询获取消息
 
         if msg is None:
             continue
@@ -132,7 +132,7 @@ async def baidu_sms_kafka_consumer(ns={}):
             pass
         else:
             try:
-                with open('baidu_kafka_msg.txt', 'a', encoding='utf-8') as f:
+                with open('/d/zhc/baidu_kafka_msg.txt', 'a', encoding='utf-8') as f:
                     f.write(f"{datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}-{msg.value().decode('utf-8')}\n")
                 
                 # print('Received message: {}'.format(msg.value().decode('utf-8')))