Test case 1: ALTER TABLE WITH ADD FOREIGN KEY [2017-03-18 16:22:13,022] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489834331000, eventType=QUERY, serverId=13, headerLength=19, dataLength=150, nextPosition=3966241, flags=0}, data=QueryEventData{threadId=39090, executionTime=2, errorCode=0, database='NextReports', sql='alter table test_sanjay add foreign key(other_id) references test_divya(other_id)'}} (io.debezium.connector.mysql.BinlogReader:435) [2017-03-18 16:22:13,023] DEBUG Recorded DDL statements for database 'NextReports': alter table test_sanjay add foreign key(other_id) references test_divya(other_id) (io.debezium.connector.mysql.BinlogReader:463) Test case 2: ALTER TABLE WITH DROP FOREIGN KEY [2017-03-18 16:37:17,200] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489835236000, eventType=QUERY, serverId=13, headerLength=19, dataLength=128, nextPosition=4143705, flags=0}, data=QueryEventData{threadId=39090, executionTime=1, errorCode=0, database='NextReports', sql='alter table test_sanjay drop foreign key test_sanjay_ibfk_1'}} (io.debezium.connector.mysql.BinlogReader:435) [2017-03-18 16:37:17,201] DEBUG Recorded DDL statements for database 'NextReports': alter table test_sanjay drop foreign key test_sanjay_ibfk_1 (io.debezium.connector.mysql.BinlogReader:463) [2017-03-18 16:37:17,749] INFO 5 records sent during previous 00:27:52.0, last recorded offset: {ts_sec=1489835236, file=mysql-bin.001162, pos=4143209, server_id=13, event=4} (io.debezium.connector.mysql.BinlogReader:273) Test case 3: ALTER TABLE WITH CHANGE COLUMN [2017-03-18 15:49:51,628] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489832390000, eventType=QUERY, serverId=13, headerLength=19, dataLength=130, nextPosition=3511023, flags=0}, data=QueryEventData{threadId=39090, executionTime=1, errorCode=0, database='NextReports', sql='ALTER TABLE test_sanjay CHANGE COLUMN id other_id bigint(20)'}} (io.debezium.connector.mysql.BinlogReader:435) [2017-03-18 15:49:51,634] DEBUG Recorded DDL statements for database 'NextReports': ALTER TABLE test_sanjay CHANGE COLUMN id other_id bigint(20) (io.debezium.connector.mysql.BinlogReader:463) Test case 4: ALTER TABLE WITH ADD INDEX [2017-03-18 17:08:01,349] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489837080000, eventType=QUERY, serverId=13, headerLength=19, dataLength=128, nextPosition=4801323, flags=0}, data=QueryEventData{threadId=39090, executionTime=1, errorCode=0, database='NextReports', sql='ALTER TABLE `test_sanjay` ADD INDEX `other_id` (`other_id`)'}} (io.debezium.connector.mysql.BinlogReader:435) [2017-03-18 17:08:01,350] DEBUG Recorded DDL statements for database 'NextReports': ALTER TABLE `test_sanjay` ADD INDEX `other_id` (`other_id`) (io.debezium.connector.mysql.BinlogReader:463) Test case 5: ALTER TABLE WITH DROP INDEX [2017-03-18 17:40:13,103] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489839012000, eventType=QUERY, serverId=13, headerLength=19, dataLength=116, nextPosition=5297845, flags=0}, data=QueryEventData{threadId=39090, executionTime=1, errorCode=0, database='NextReports', sql='ALTER TABLE `test_sanjay` drop INDEX `other_id`'}} (io.debezium.connector.mysql.BinlogReader:435) [2017-03-18 17:40:13,104] DEBUG Recorded DDL statements for database 'NextReports': ALTER TABLE `test_sanjay` drop INDEX `other_id` (io.debezium.connector.mysql.BinlogReader:463)