2017-11-02 12:41:06,902 ERROR MySQL|dev_db1|binlog Error parsing DDL statement and updating tables: create table xxxxxxxx_definition(
yyyyyyyyy int(11),
order_num int(11),
definition_type text(20)
) [io.debezium.connector.mysql.MySqlSchema]
2017-11-02 12:41:06,906 ERROR MySQL|dev_db1|binlog Failed due to error: Error processing binlog event [io.debezium.connector.mysql.BinlogReader]
org.apache.kafka.connect.errors.ConnectException: Expecting ')' at line 4, column 21 but found '(': definition_type text ===>> (20)
)
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:178)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:156)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:336)
at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1055)
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:913)
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:559)
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:793)
at java.lang.Thread.run(Thread.java:748)
Caused by: io.debezium.text.ParsingException: Expecting ')' at line 4, column 21 but found '(': definition_type text ===>> (20)
)
at io.debezium.text.TokenStream.consume(TokenStream.java:706)
at io.debezium.connector.mysql.MySqlDdlParser.parseCreateDefinitionList(MySqlDdlParser.java:563)
at io.debezium.connector.mysql.MySqlDdlParser.parseCreateTable(MySqlDdlParser.java:378)
at io.debezium.connector.mysql.MySqlDdlParser.parseCreate(MySqlDdlParser.java:281)
at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:152)
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:359)
at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:469)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:323)
... 5 more
2017-11-02 12:41:06,912 INFO MySQL|dev_db1|binlog Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. [io.debezium.connector.mysql.BinlogReader]
2017-11-02 12:41:07,192 ERROR || Task inventory-connector-0 threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask]