-
Bug
-
Resolution: Done
-
Major
-
0.6
-
None
Kafka Connect log:
2017-10-17 13:20:51,306 ERROR MySQL|db1|binlog Error parsing DDL statement and updating tables: CREATE TABLE `abc` ( `def` int(11) unsigned NOT NULL AUTO_INCREMENT, `ghi` int(11) NOT NULL DEFAULT '0', `jkl` tinyint(4) unsigned NOT NULL, `mno` varchar(255) NOT NULL DEFAULT '', `pqr` int(11) NOT NULL DEFAULT '0', `column` varchar(255) NOT NULL DEFAULT '', PRIMARY KEY (`def`), KEY `stu` (`jkl`,`ghi`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 [io.debezium.connector.mysql.MySqlSchema] io.debezium.text.ParsingException: Expecting ')' at line 7, column 20 but found '255': `column` varchar( ===>> 255) NOT NULL DEFAUL at io.debezium.text.TokenStream.consume(TokenStream.java:706) at io.debezium.connector.mysql.MySqlDdlParser.parseCreateDefinitionList(MySqlDdlParser.java:559) at io.debezium.connector.mysql.MySqlDdlParser.parseCreateTable(MySqlDdlParser.java:376) at io.debezium.connector.mysql.MySqlDdlParser.parseCreate(MySqlDdlParser.java:279) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:150) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:286) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:461) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319) 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)