refactor: canal消息对象优化

This commit is contained in:
郝先瑞 2022-07-31 15:47:28 +08:00
parent 5660e91bdb
commit 99a743cdcc

View File

@ -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<T> {
@JsonProperty("type")
private String type;
@JsonProperty("table")
private String table;
@JsonProperty("data")
private List<T> 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<T> old;
@JsonProperty("pkNames")
private List<String> pkNames;
@JsonProperty("sql")
private String sql;
@JsonProperty("ts")
private Long ts;
}