H Vs hace 4 semanas
padre
commit
6e150a7220
Se han modificado 1 ficheros con 2 adiciones y 1 borrados
  1. +2
    -1
      services/kafka_service.py

+ 2
- 1
services/kafka_service.py Ver fichero

@@ -130,7 +130,8 @@ class KafkaService:
try:
async for msg in self.consumer:
try:
logger.info(f"接收到kafka消息: {json.dumps(json.loads(msg.value.decode()), ensure_ascii=False)}")
# logger.info(f"接收到kafka消息: {json.dumps(json.loads(msg.value.decode()), ensure_ascii=False)}")
logger.info(f"接收到kafka消息: {json.dumps(json.loads(msg.value.decode()), ensure_ascii=False)[:300]}")
topic = msg.topic
if topic in self.message_handlers:
handler = self.message_handlers[topic]


Cargando…
Cancelar
Guardar