org.apache.kafka.connect.errors.ConnectException: Failed to parse statement 'ALTER TABLE ***.**** ADD PARTITION(PARTITION p201901 VALUES LESS THAN (737425) ENGINE = InnoDB)'
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:200)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:178)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:444)
at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1055)
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:913)
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:559)
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:793)
at java.lang.Thread.run(Thread.java:745)
Caused by: io.debezium.text.ParsingException: Failed to parse statement 'ALTER TABLE ***.**** ADD PARTITION(PARTITION p201901 VALUES LESS THAN (737425) ENGINE = InnoDB)'
at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:292)
at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267)
at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:322)
at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:615)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:428)
... 5 more