-
Bug
-
Resolution: Done
-
Minor
-
None
-
None
-
False
-
False
-
Undefined
-
Debezium connector for MySQL failing when parsing DDL.
We are currently using Debezium version 1.4.2.Final
innodb_version=5.7.26-29
mysql version=5.7.26-29-log
"trace": "org.apache.kafka.connect.errors.ConnectException: Encountered change event for table searchjobdb.tblSRCHjob_desc whose schema isn't known to this connector at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:607) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1104) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:955) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table searchjobdb.tblSRCHjob_desc whose schema isn't known to this connector at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:875) at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:849) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:590) ... 5 more "
The offending DDL is:
CREATE TABLE `tblSRCHjob_desc` (\n `description_id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,\n `description` mediumtext NOT NULL,\n PRIMARY KEY (`description_id`)\n) ENGINE=TokuDB AUTO_INCREMENT=4095997820 DEFAULT CHARSET=utf8mb4 ROW_FORMAT=TOKUDB_QUICKLZ