Debezium mysql DDL statement couldn't be parsed

2021-05-26 18:44:17,777] ERROR Unexpected exception while processing record 'ConsumerRecord(topic = dbhistory.cdc_yk, partition = 0, leaderEpoch = 0, offset = 1, CreateTime = 1622025024939, serialized key size = -1, serialized value size = 389, headers = RecordHeaders(headers = [], isReadOnly = false), key = null, value = {2021-05-26 18:44:17,777] ERROR Unexpected exception while processing record 'ConsumerRecord(topic = dbhistory.cdc_yk, partition = 0, leaderEpoch = 0, offset = 1, CreateTime = 1622025024939, serialized key size = -1, serialized value size = 389, headers = RecordHeaders(headers = [], isReadOnly = false), key = null, value = {  "source" : {    "server" : "cdc_yk"  },  "position" : {    "ts_sec" : 1622025014,    "file" : "mysql-bin.016059",    "pos" : 23393,    "gtids" : "3e0370e0-f240-11ea-93de-fa163ef18682:1-4859239,70cc1628-8298-11eb-811d-fa163ee07977:1-1083755",    "snapshot" : true  },  "databaseName" : "yk_myscrm_xfztc_test",  "ddl" : "DROP TABLE IF EXISTS 1673315",  "tableChanges" : [ ]})' (io.debezium.relational.history.KafkaDatabaseHistory:319)io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'DROP TABLE IF EXISTS 1673315'no viable alternative at input 'DROP TABLE IF EXISTS 1673315' at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1157) at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:885) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:72) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:80) at io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$1(AbstractDatabaseHistory.java:134) at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:307) at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:101) at io.debezium.relational.HistorizedRelationalDatabaseSchema.recover(HistorizedRelationalDatabaseSchema.java:49) at io.debezium.connector.mysql.MySqlConnectorTask.validateAndLoadDatabaseHistory(MySqlConnectorTask.java:311) at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:96) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:189) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:238) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)Caused by: org.antlr.v4.runtime.NoViableAltException at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026) at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467) at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:959) ... 19 more[2021-05-26 18:44:17,778] INFO [Consumer clientId=cdc_yk-dbhistory, groupId=cdc_yk-dbhistory] Revoke previously assigned partitions dbhistory.cdc_yk-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:307)[2021-05-26 18:44:17,778] INFO [Consumer clientId=cdc_yk-dbhistory, groupId=cdc_yk-dbhistory] Member cdc_yk-dbhistory-5745c17c-7259-4d68-9833-ed2f1b6ef594 sending LeaveGroup request to coordinator 10.9.64.120:9092 (id: 2147482646 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1038)[2021-05-26 18:44:17,779] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:668)[2021-05-26 18:44:17,780] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:672)[2021-05-26 18:44:17,780] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:678)[2021-05-26 18:44:17,781] INFO App info kafka.consumer for cdc_yk-dbhistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)[2021-05-26 18:44:17,781] INFO WorkerSourceTask{id=cdc_source_yk_202105261829-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:485)[2021-05-26 18:44:17,781] INFO WorkerSourceTask{id=cdc_source_yk_202105261829-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:502)[2021-05-26 18:44:17,781] ERROR WorkerSourceTask{id=cdc_source_yk_202105261829-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:191)io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'DROP TABLE IF EXISTS 1673315'no viable alternative at input 'DROP TABLE IF EXISTS 1673315' at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1157) at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:885) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:72) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:80) at io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$1(AbstractDatabaseHistory.java:134) at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:307) at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:101) at io.debezium.relational.HistorizedRelationalDatabaseSchema.recover(HistorizedRelationalDatabaseSchema.java:49) at io.debezium.connector.mysql.MySqlConnectorTask.validateAndLoadDatabaseHistory(MySqlConnectorTask.java:311) at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:96) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:189) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:238) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)Caused by: org.antlr.v4.runtime.NoViableAltException at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026) at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467) at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:959) ... 19 more