update:数据同步统一使用枚举类
This commit is contained in:
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user