diff --git a/kgadget/src/baidu_sms_kafka_consumer.py b/kgadget/src/baidu_sms_kafka_consumer.py
index 9e968e0..90d2153 100644
--- a/kgadget/src/baidu_sms_kafka_consumer.py
+++ b/kgadget/src/baidu_sms_kafka_consumer.py
@@ -125,10 +125,10 @@ async def baidu_sms_kafka_consumer(ns={}):
     # total_count = 0
     while True:
         i = 0
-        # 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")
+        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)  # 单次轮询获取消息