From b7ec17694ddf4f79a1322a330b4b210d667d48ce Mon Sep 17 00:00:00 2001 From: hewencai <2357300448@qq.com> Date: Mon, 15 Dec 2025 20:04:43 +0800 Subject: [PATCH] =?UTF-8?q?update=EF=BC=9A=E6=95=B0=E6=8D=AE=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E7=BB=9F=E4=B8=80=E4=BD=BF=E7=94=A8=E6=9E=9A=E4=B8=BE?= =?UTF-8?q?=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../databus/client/core/listener/DatabusConsumerRegistry.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/zt-framework/zt-spring-boot-starter-databus-client/src/main/java/com/zt/plat/framework/databus/client/core/listener/DatabusConsumerRegistry.java b/zt-framework/zt-spring-boot-starter-databus-client/src/main/java/com/zt/plat/framework/databus/client/core/listener/DatabusConsumerRegistry.java index bf1ba313..a38a9fe9 100644 --- a/zt-framework/zt-spring-boot-starter-databus-client/src/main/java/com/zt/plat/framework/databus/client/core/listener/DatabusConsumerRegistry.java +++ b/zt-framework/zt-spring-boot-starter-databus-client/src/main/java/com/zt/plat/framework/databus/client/core/listener/DatabusConsumerRegistry.java @@ -106,7 +106,7 @@ public class DatabusConsumerRegistry { for (MessageExt msg : msgs) { try { String messageBody = new String(msg.getBody(), StandardCharsets.UTF_8); - log.debug("[Databus Client] 收到消息, topic={}, msgId={}, eventType={}", + log.info("[Databus Client] 收到消息, topic={}, msgId={}, eventType={}", msg.getTopic(), msg.getMsgId(), eventType.name()); messageProcessor.process(messageBody, eventType);