From 99a743cdcc19822012f3bb0044973684f9690c20 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=83=9D=E5=85=88=E7=91=9E?= <1490493387@qq.com> Date: Sun, 31 Jul 2022 15:47:28 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20canal=E6=B6=88=E6=81=AF=E5=AF=B9?= =?UTF-8?q?=E8=B1=A1=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/youlai/common/web/domain/CanalMessage.java | 13 +------------ 1 file changed, 1 insertion(+), 12 deletions(-) diff --git a/youlai-common/common-web/src/main/java/com/youlai/common/web/domain/CanalMessage.java b/youlai-common/common-web/src/main/java/com/youlai/common/web/domain/CanalMessage.java index 73ad517f..893607e2 100644 --- a/youlai-common/common-web/src/main/java/com/youlai/common/web/domain/CanalMessage.java +++ b/youlai-common/common-web/src/main/java/com/youlai/common/web/domain/CanalMessage.java @@ -7,7 +7,7 @@ import lombok.NoArgsConstructor; import java.util.List; /** - * Canal 消息监听 + * Canal 消息对象 * * @author haoxr * @date 2021/11/4 23:59 @@ -15,26 +15,15 @@ import java.util.List; @NoArgsConstructor @Data public class CanalMessage { - @JsonProperty("type") private String type; - @JsonProperty("table") private String table; - @JsonProperty("data") private List data; - @JsonProperty("database") private String database; - @JsonProperty("es") private Long es; - @JsonProperty("id") private Integer id; - @JsonProperty("isDdl") private Boolean isDdl; - @JsonProperty("old") private List old; - @JsonProperty("pkNames") private List pkNames; - @JsonProperty("sql") private String sql; - @JsonProperty("ts") private Long ts; } -- GitLab