[2021-04-26 19:04:49,635] ERROR Failed due to error: Error processing binlog event (io.debezium.connector.mysql.BinlogReader:219) org.apache.kafka.connect.errors.ConnectException: DDL statement couldn't be parsed. Please open a Jira issue with the statement '/* ApplicationName=DBe aver 5.3.5 - Main */ CREATE TABLE test_schema.ts (id INT, purchased DATE) PARTITION BY RANGE( YEAR(purchased) ) SUBPARTITION BY HASH( TO_DAYS(purchased) ) ( PARTITION p0 VALUES LESS THAN (1990) ( SUBPARTITION s0, SUBPARTITION s1 ), PARTITION p1 VALUES LESS THAN (2000) ( SUBPARTITION s2, SUBPARTITION s3 ), PARTITION p2 VALUES LESS THAN MAXVALUE ( SUBPARTITION s4, SUBPARTITION s5 ) )' no viable alternative at input 'CREATE TABLE test_schema.ts (id INT, purchased DATE)\r\n PARTITION BY RANGE( YEAR(purchased) )\r\n SUBPARTITION B Y HASH( TO_DAYS(purchased) ) (\r\n PARTITION p0 VALUES LESS THAN (1990) (' at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:607) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1100) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:951) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:594) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:838) at java.lang.Thread.run(Thread.java:748)