org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: 
Expecting token type 128 at line 1, column 8 but found 'USER': RENAME  ===>> USER 'wujin'@'211.10
at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:192)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:137)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
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:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)\nCaused by: io.debezium.text.ParsingException: 
Expecting token type 128 at line 1, column 8 but found 'USER': RENAME  ===>> USER 'wujin'@'211.10
at io.debezium.text.TokenStream.consume(TokenStream.java:737)
at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:568)
at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:376)
at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:168)
at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:286)
at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267)
at io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$0(AbstractDatabaseHistory.java:61)
at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:212)
at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:55)
at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:315)
at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:116)
at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:80)
... 8 more\n