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