我已经在 Kafka 连接中集成了 debezium 连接器来流式传输我的 mysql 数据库更改。对于某些程序，它无法读取 binlog 文件。有什么建议或解决方法吗？卡住了这个问题。我可以在 mysql 中指定不要将 ddl 日志放入 binlog 文件吗？
2017-10-10 15:20:22,314 ERROR MySQL|dbStreamer|binlog Failed due to error: Error processing binlog event [io.debezium.connector.mysql.BinlogReader]
org.apache.kafka.connect.errors.ConnectException: Unexpected exception (One or more errors trying to parse statement at line 1, column 8) parsing at line 1, column 8
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:142)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:332)
at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902)
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760)
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
at java.lang.Thread.run(Thread.java:748)
Caused by: io.debezium.text.ParsingException: Unexpected exception (One or more errors trying to parse statement at line 1, column 8) parsing at line 1, column 8
at io.debezium.relational.ddl.DdlParser.parsingFailed(DdlParser.java:660)
at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:294)
at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267)
at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:354)
at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:461)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319)
... 5 more
Caused by: One or more errors trying to parse statement at line 1, column 8
io.debezium.text.ParsingException: Expecting VIEW at line 1, column 35 but found 'PROCEDURE': =`root`@`localhost` ===>> PROCEDURE `azuga`.`c
io.debezium.text.ParsingException: No more content