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]