zgty/zt-dsc
9
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update：数据同步统一使用枚举类

Browse Source
This commit is contained in:
hewencai
2025-12-15 20:04:43 +08:00
parent 951b9bf67d
commit b7ec17694d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
zt-framework/zt-spring-boot-starter-databus-client/src/main/java/com/zt/plat/framework/databus/client/core/listener/DatabusConsumerRegistry.java
View File

@@ -106,7 +106,7 @@ public class DatabusConsumerRegistry {
for (MessageExt msg : msgs) { for (MessageExt msg : msgs) {
try { try {
String messageBody = new String(msg.getBody(), StandardCharsets.UTF_8); 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()); msg.getTopic(), msg.getMsgId(), eventType.name());
messageProcessor.process(messageBody, eventType); messageProcessor.process(messageBody, eventType);