2017-10-10 2 views
0

私はKafkaにdebeziumコネクタを統合して、私のmysql dbの変更をストリームします。いくつかの手順では、binlogファイルを読み取ることができません。任意の提案や回避策?この問題を抱えてmysqlでddlログをbinlogファイルに入れないように指定できますか?java - DebeziumはDDL(create proc)文を解析できません。mysql connector

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 
+0

** 1行目、35行目のVIEWを期待していますが、「手順」が見つかりました** – Sabya

答えて

0

あなたはissue tracker. DDLパーサーに問題を提起する必要があることはプロシージャを作成するための(スキップ)ステートメントを処理することができますが、完璧ではありません。あなたが問題のコードを提供できるならば、私たちはパーサをコンパイルすることができます。

+0

解決済み。このプロパティー "database.history.skip.unparseable.ddl"をtrueに設定すると、解析できないddlステートメントはすべて無視されます。 – Sabya

+0

これは、実際のソリューションよりも多くの修正プログラムです。問題は、将来、スキーマがデータに準拠していない状況で、プロシージャではなくテーブルにrealtestする他の解析不可能なDDLを満たす場合です。 –

関連する問題