|
@@ -42,7 +42,6 @@ public class MessageUtil {
|
|
CanalEntry.EventType eventType = rowChange.getEventType();
|
|
CanalEntry.EventType eventType = rowChange.getEventType();
|
|
|
|
|
|
final CommonMessage msg = new CommonMessage();
|
|
final CommonMessage msg = new CommonMessage();
|
|
- msg.setIsDdl(rowChange.getIsDdl());
|
|
|
|
msg.setDatabase(entry.getHeader().getSchemaName());
|
|
msg.setDatabase(entry.getHeader().getSchemaName());
|
|
msg.setTable(entry.getHeader().getTableName());
|
|
msg.setTable(entry.getHeader().getTableName());
|
|
msg.setType(eventType.toString());
|
|
msg.setType(eventType.toString());
|