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')))