尝试在重新启动分贝后重新启动debezium mysql连接器时出错

已启用MySql ROW级别binloging。尝试在重新启动分贝后重新启动debezium mysql连接器时出错

ERROR Failed to start the connector (see other exception), but got this error while cleaning up (io.debezium.connector.mysql.MySqlConnectorTask:183) 
java.lang.NullPointerException 
     at io.debezium.connector.mysql.MySqlConnectorTask.stop(MySqlConnectorTask.java:220) 
     at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:180) 
     at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:141) 
     at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:139) 
     at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:182) 
     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) 

ERROR Task lk-mysql-connector-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:141) 
org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'DELETE': ===>> DELETE from mysql.rd 
     at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:192) 
     at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:141) 
     at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:139) 
     at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:182) 
     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) 

Caused by: io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'DELETE': ===>> DELETE from mysql.rd 
     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:156) 
     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:57) 
     at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:202) 
     at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:52) 
     at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:312) 
     at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:116) 
     at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:80) 
     ... 8 more

来源

2017-04-21 chandramohan

你可以检查出[二进制日志格式（HTTP ：//debezium.io/docs/connectors/mysql/#configuration）设置为“row”？如果是这样，是不是也许以前设置为另一个值？ – Gunnar

是的，之前它被设置为MIXED。但是如果是这样的话，它应该会自动启动失败，当重新启动mysql并尝试重新启动debezium以连接到mysql时，这种情况正在发生。 – chandramohan

尝试在重新启动分贝后重新启动debezium mysql连接器时出错

回答

相关问题