2021-05-11 08:45:01,803 ERROR WorkerSourceTask{id=mysql-connector-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) [ta io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'DROP TABLE IF EXISTS tmp_all_ogu_rsr_32BBF5F1-E357-49F9-A84F-DCE6022F626C' mismatched input '-' expecting {<EOF>, '--'}     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.reportInputMismatch(DefaultErrorStrategy.java:327)     at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139)     at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:915)     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:135)     at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:307)     at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:102)     at io.debezium.relational.HistorizedRelationalDatabaseSchema.recover(HistorizedRelationalDatabaseSchema.java:49)     at io.debezium.connector.mysql.MySqlConnectorTask.validateAndLoadDatabaseHistory(MySqlConnectorTask.java:318)     at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:100)     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:185)     at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234)     at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)     at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)     at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)     at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)     at java.base/java.lang.Thread.run(Thread.java:834) Caused by: org.antlr.v4.runtime.InputMismatchException     at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270)     at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:900)     ... 18 more