2018-06-25 21:32:16,825 WARN MySQL|dev_db1|snapshot Column is missing a character set: mno VARCHAR(64) NOT NULL DEFAULT VALUE 0 [io.debezium.connector.mysql.MySqlValueConverters]
2018-06-25 21:32:16,825 WARN MySQL|dev_db1|snapshot Using UTF-8 charset by default for column without charset: mno VARCHAR(64) NOT NULL DEFAULT VALUE 0 [io.debezium.connector.mysql.MySqlValueConverters]
2018-06-25 21:32:16,826 INFO MySQL|dev_db1|snapshot CREATE TABLE `abc` (
`def` int(11) unsigned NOT NULL AUTO_INCREMENT,
`ghi` int(11) unsigned NOT NULL,
`jkl` int(11) unsigned NOT NULL COMMENT 'comment',
`mno` varchar(64) NOT NULL DEFAULT '0' COMMENT 'comment',
`pqr` varchar(32) NOT NULL COMMENT 'comment',
`stu` varchar(16) DEFAULT NULL COMMENT 'comment',
`vwx` varchar(64) NOT NULL COMMENT 'comment',
`bcd` timestamp(3) NOT NULL DEFAULT '0000-00-00 00:00:00.000' COMMENT 'comment',
`efg` timestamp(3) NOT NULL DEFAULT '0000-00-00 00:00:00.000' COMMENT 'comment',
`hij` timestamp(3) NOT NULL DEFAULT '0000-00-00 00:00:00.000' COMMENT 'comment',
`klm` varchar(255) DEFAULT NULL COMMENT 'comment',
`nop` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`qrs` int(11) DEFAULT NULL,
PRIMARY KEY (`def`)
) ENGINE=InnoDB AUTO_INCREMENT=1955 DEFAULT CHARSET=utf8 COMMENT='comment' [io.debezium.connector.mysql.SnapshotReader]
2018-06-25 21:32:16,829 INFO MySQL|dev_db1|snapshot Step 7: rolling back transaction after abort [io.debezium.connector.mysql.SnapshotReader]
2018-06-25 21:32:16,831 ERROR MySQL|dev_db1|snapshot Failed due to error: Aborting snapshot due to error when last running 'ROLLBACK': Timestamp format must be yyyy-mm-dd hh:mm:ss[.fffffffff] [io.debezium.connector.mysql.SnapshotReader]
org.apache.kafka.connect.errors.ConnectException: Timestamp format must be yyyy-mm-dd hh:mm:ss[.fffffffff]
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:200)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:178)
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:692)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalArgumentException: Timestamp format must be yyyy-mm-dd hh:mm:ss[.fffffffff]
at java.sql.Timestamp.valueOf(Timestamp.java:237)
at io.debezium.connector.mysql.MySqlDefaultValuePreConverter.convertToTimestamp(MySqlDefaultValuePreConverter.java:129)
at io.debezium.connector.mysql.MySqlDefaultValuePreConverter.convert(MySqlDefaultValuePreConverter.java:58)
at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.convertDefaultValueToSchemaType(ColumnDefinitionParserListener.java:261)
at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.enterDefaultValue(ColumnDefinitionParserListener.java:129)
at io.debezium.ddl.parser.mysql.generated.MySqlParser$DefaultValueContext.enterRule(MySqlParser.java:48914)
at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:45)
at io.debezium.connector.mysql.antlr.listener.MySqlAntlrDdlParserListener.enterEveryRule(MySqlAntlrDdlParserListener.java:89)
at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:41)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:25)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:85)
at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:344)
at io.debezium.connector.mysql.SnapshotReader.lambda$execute$12(SnapshotReader.java:441)
at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:393)
at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:348)
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:439)
... 3 more
2018-06-25 21:32:17,023 INFO || WorkerSourceTask{id=inventory-connector-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
2018-06-25 21:32:17,023 INFO || WorkerSourceTask{id=inventory-connector-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
2018-06-25 21:32:17,032 INFO || Cluster ID: 5GrwXr9pS1uvmX43LO8tdw [org.apache.kafka.clients.Metadata]
2018-06-25 21:32:17,048 INFO || WorkerSourceTask{id=inventory-connector-0} Finished commitOffsets successfully in 25 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
2018-06-25 21:32:17,048 ERROR || WorkerSourceTask{id=inventory-connector-0} Task threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: Timestamp format must be yyyy-mm-dd hh:mm:ss[.fffffffff]
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:200)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:178)
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:692)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalArgumentException: Timestamp format must be yyyy-mm-dd hh:mm:ss[.fffffffff]
at java.sql.Timestamp.valueOf(Timestamp.java:237)
at io.debezium.connector.mysql.MySqlDefaultValuePreConverter.convertToTimestamp(MySqlDefaultValuePreConverter.java:129)
at io.debezium.connector.mysql.MySqlDefaultValuePreConverter.convert(MySqlDefaultValuePreConverter.java:58)
at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.convertDefaultValueToSchemaType(ColumnDefinitionParserListener.java:261)
at io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.enterDefaultValue(ColumnDefinitionParserListener.java:129)
at io.debezium.ddl.parser.mysql.generated.MySqlParser$DefaultValueContext.enterRule(MySqlParser.java:48914)
at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:45)
at io.debezium.connector.mysql.antlr.listener.MySqlAntlrDdlParserListener.enterEveryRule(MySqlAntlrDdlParserListener.java:89)
at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:41)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:25)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:85)
at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:344)
at io.debezium.connector.mysql.SnapshotReader.lambda$execute$12(SnapshotReader.java:441)
at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:393)
at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:348)
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:439)
... 3 more
2018-06-25 21:32:17,048 ERROR || WorkerSourceTask{id=inventory-connector-0} Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask]
2018-06-25 21:32:17,048 INFO || [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer]
2018-06-25 21:33:06,953 INFO || WorkerSourceTask{id=inventory-connector-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
2018-06-25 21:33:06,954 INFO || WorkerSourceTask{id=inventory-connector-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
Bug
Major
