2018-06-25 19:59:37,039 ERROR  MySQL|dev_db1|binlog  Error during binlog processing. Last offset stored = {ts_sec=1529956748, file=dev-db1-bin.000031, pos=6198067, server_id=1, event=1}, binlog reader near position = dev-db1-bin.000031/6198067   [io.debezium.connector.mysql.BinlogReader]
2018-06-25 19:59:37,040 ERROR  MySQL|dev_db1|binlog  Failed due to error: Error processing binlog event   [io.debezium.connector.mysql.BinlogReader]
org.apache.kafka.connect.errors.ConnectException: Trying to change column column_name in db_name.table_name table, which does not exists. Query: CHANGE `column_name` `column_name` ENUM('Foo','Bar','Baz') CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT 'Foo'
        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.BinlogReader.handleEvent(BinlogReader.java:452)
        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: Trying to change column column_name in db_name.table_name table, which does not exists. Query: CHANGE `column_name` `column_name` ENUM('Foo','Bar','Baz') CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT 'Foo'
        at io.debezium.connector.mysql.antlr.listener.AlterTableParserListener.lambda$enterAlterByChangeColumn$7(AlterTableParserListener.java:152)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.runIfNotNull(MySqlAntlrDdlParser.java:285)
        at io.debezium.connector.mysql.antlr.listener.AlterTableParserListener.enterAlterByChangeColumn(AlterTableParserListener.java:143)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser$AlterByChangeColumnContext.enterRule(MySqlParser.java:12540)
        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 io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:85)
        at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:344)
        at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:637)
        at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:436)
        ... 5 more
2018-06-25 19:59:37,041 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]
2018-06-25 19:59:37,318 INFO   ||  WorkerSourceTask{id=inventory-connector-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2018-06-25 19:59:37,318 INFO   ||  WorkerSourceTask{id=inventory-connector-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2018-06-25 19:59:37,318 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: Trying to change column column_name in db_name.table_name table, which does not exists. Query: CHANGE `column_name` `column_name` ENUM('Foo','Bar','Baz') CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT 'Foo'
        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.BinlogReader.handleEvent(BinlogReader.java:452)
        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: Trying to change column column_name in db_name.table_name table, which does not exists. Query: CHANGE `column_name` `column_name` ENUM('Foo','Bar','Baz') CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT 'Foo'
        at io.debezium.connector.mysql.antlr.listener.AlterTableParserListener.lambda$enterAlterByChangeColumn$7(AlterTableParserListener.java:152)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.runIfNotNull(MySqlAntlrDdlParser.java:285)
        at io.debezium.connector.mysql.antlr.listener.AlterTableParserListener.enterAlterByChangeColumn(AlterTableParserListener.java:143)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser$AlterByChangeColumnContext.enterRule(MySqlParser.java:12540)
        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 io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:85)
        at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:344)
        at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:637)
        at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:436)
        ... 5 more
2018-06-25 19:59:37,318 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 19:59:37,319 INFO   ||  [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2018-06-25 20:00:12,420 INFO   ||  WorkerSourceTask{id=inventory-connector-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2018-06-25 20:00:12,421 INFO   ||  WorkerSourceTask{id=inventory-connector-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]