[2017-03-17 11:10:42,143] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 0 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:358) [2017-03-17 11:12:22,145] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 0 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:358) [2017-03-17 11:41:16,842] ERROR Error parsing DDL statement and updating tables: ALTER TABLE ACADEMIC_TERM DROP INDEX IDX__ACADEMIC_SESSION_ID (io.debezium.connector.mysql.MySqlSchema:353) io.debezium.text.ParsingException: No more content but was expecting token ON at io.debezium.text.TokenStream.consume(TokenStream.java:659) at io.debezium.connector.mysql.MySqlDdlParser.parseDropIndex(MySqlDdlParser.java:1256) at io.debezium.connector.mysql.MySqlDdlParser.parseDrop(MySqlDdlParser.java:1211) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:145) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:447) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:313) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472) at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657) at java.lang.Thread.run(Thread.java:745) [2017-03-17 11:41:22,173] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:358) [2017-03-17 11:50:44,071] INFO 160 records sent during previous 01:20:39.0, last recorded offset: {ts_sec=1489730900, file=mysql-bin.000280, pos=70859419, server_id=204658455, event=7} (io.debezium.connector.mysql.BinlogReader:267) [2017-03-17 11:50:44,135] ERROR Error parsing DDL statement and updating tables: ALTER TABLE TERM_CLASS_MAPPING DROP INDEX IDX__ACADEMIC_TERM_ID (io.debezium.connector.mysql.MySqlSchema:353) io.debezium.text.ParsingException: No more content but was expecting token ON at io.debezium.text.TokenStream.consume(TokenStream.java:659) at io.debezium.connector.mysql.MySqlDdlParser.parseDropIndex(MySqlDdlParser.java:1256) at io.debezium.connector.mysql.MySqlDdlParser.parseDrop(MySqlDdlParser.java:1211) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:145) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:447) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:313) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472) at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657) at java.lang.Thread.run(Thread.java:745) [2017-03-17 11:50:44,147] ERROR Error parsing DDL statement and updating tables: ALTER TABLE TERM_CLASS_MAPPING DROP INDEX IDX__ACADEMIC_SESSION_ID (io.debezium.connector.mysql.MySqlSchema:353) io.debezium.text.ParsingException: No more content but was expecting token ON at io.debezium.text.TokenStream.consume(TokenStream.java:659) at io.debezium.connector.mysql.MySqlDdlParser.parseDropIndex(MySqlDdlParser.java:1256) at io.debezium.connector.mysql.MySqlDdlParser.parseDrop(MySqlDdlParser.java:1211) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:145) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:447) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:313) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472) at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657) at java.lang.Thread.run(Thread.java:745) [2017-03-17 11:50:44,250] ERROR Error parsing DDL statement and updating tables: alter table TERM_CLASS_MAPPING drop index FK49g86x92f1g2r2qemnhbf8pxr (io.debezium.connector.mysql.MySqlSchema:353) io.debezium.text.ParsingException: No more content but was expecting token ON at io.debezium.text.TokenStream.consume(TokenStream.java:659) at io.debezium.connector.mysql.MySqlDdlParser.parseDropIndex(MySqlDdlParser.java:1256) at io.debezium.connector.mysql.MySqlDdlParser.parseDrop(MySqlDdlParser.java:1211) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:145) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:447) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:313) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472) at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657) at java.lang.Thread.run(Thread.java:745) [2017-03-17 11:50:52,184] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 3 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:358) [2017-03-17 11:52:52,186] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 1 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:358) [2017-03-17 12:10:32,201] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 1 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:358) [2017-03-17 12:11:22,202] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 1 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:358) [2017-03-17 12:12:52,204] INFO Finished WorkerSourceTask{id=qa_msr_cluster-connector-0} commitOffsets successfully in 1 ms (org.apache