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

Merge branch 'dev' into 'test'

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

See merge request jygk/dsc!8
This commit is contained in:
wencai he
2025-12-15 12:05:35 +00:00
parent 6fc1dface2 b7ec17694d
commit fffea61d51
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);