调整

services/kafka_service.py

@@ -70,8 +70,11 @@ class KafkaService:
         
         target_topic = topic or self.producer_topic
         print(f'生产者topic:{target_topic}')
+        json_str = json.dumps(json.loads(message), ensure_ascii=False)
+        truncated = json_str if len(json_str) <= 300 else f"{json_str[:297]}..."
+        logger.info(f"生产者topic:{target_topic}\n生产者消息:{truncated}")                
         #logger.info(f"生产者topic:{target_topic}\n生产者消息:{json.dumps(json.loads(message), separators=(',', ':'), default=str, ensure_ascii=False)}")
-        print(f"生产者topic:{target_topic}\n生产者消息:{json.dumps(json.loads(message), separators=(',', ':'), default=str, ensure_ascii=False)}")
+        #print(f"生产者topic:{target_topic}\n生产者消息:{json.dumps(json.loads(message), separators=(',', ':'), default=str, ensure_ascii=False)}")
         try:
             await self.producer.send_and_wait(
                 target_topic,