@@ -60,6 +60,7 @@ public abstract class AbstractMysqlEventParser extends AbstractEventParser {
convert.setFilterQueryDdl(filterQueryDdl);
convert.setFilterRows(filterRows);
convert.setFilterTableError(filterTableError);
+ convert.setUseDruidDdlFilter(useDruidDdlFilter);
return convert;
}
@@ -981,4 +981,8 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar
public void setFilterRows(boolean filterRows) {
this.filterRows = filterRows;
+
+ public void setUseDruidDdlFilter(boolean useDruidDdlFilter) {
+ this.useDruidDdlFilter = useDruidDdlFilter;
+ }