[2017-03-17 20:17:20,134] INFO Source task WorkerSourceTask{id=msri-connector-0} finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:138)
[2017-03-17 20:17:20,176] DEBUG Rotating logs: Event{header=EventHeaderV4{timestamp=0, eventType=ROTATE, serverId=308, headerLength=19, dataLength=28, nextPosition=0, flags=32}, data=RotateEventData{binlogFilename='mysql-bin.000214', binlogPosition=25557317}} (io.debezium.connector.mysql.BinlogReader:386)
[2017-03-17 20:17:20,178] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489755214000, eventType=QUERY, serverId=13, headerLength=19, dataLength=44, nextPosition=25557380, flags=8}, data=QueryEventData{threadId=245158, executionTime=158, errorCode=0, database='', sql='BEGIN'}} (io.debezium.connector.mysql.BinlogReader:422)
[2017-03-17 20:17:20,178] DEBUG Restarting partially-processed transaction; change events will not be created for the first 2 events plus 1 more rows in the next event (io.debezium.connector.mysql.BinlogReader:429)
[2017-03-17 20:17:20,182] DEBUG Received update table metadata event: Event{header=EventHeaderV4{timestamp=1489755214000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=121, nextPosition=25557520, flags=0}, data=TableMapEventData{tableId=283719, database='NextServices', table='STAFF', columnTypes=8, 15, 8, 15, 15, 8, 8, 18, 10, 10, 15, 15, 15, 15, 15, 15, 15, 15, 10, 15, 8, 15, 15, 8, 18, 8, 15, 15, 15, 15, 8, 15, 15, 1, 10, 8, 8, 8, 8, columnMetadata=0, 75, 0, 60, 60, 0, 0, 0, 0, 0, 765, 300, 150, 75, 75, 75, 60, 150, 0, 75, 0, 60, 75, 0, 0, 0, 60, 150, 60, 60, 0, 765, 90, 0, 0, 0, 0, 0, 0, columnNullability={1, 2, 3, 4, 7, 8, 9, 10, 11, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38}}} (io.debezium.connector.mysql.BinlogReader:475)
[2017-03-17 20:17:20,191] DEBUG Skipping previously processed update event: Event{header=EventHeaderV4{timestamp=1489755214000, eventType=EXT_UPDATE_ROWS, serverId=13, headerLength=19, dataLength=129, nextPosition=25557668, flags=0}, data=UpdateRowsEventData{tableId=283719, includedColumnsBeforeUpdate={0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38}, includedColumns={0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38}, rows=[
    {before=[754, null, null, null, null, 1135886, 677159, 2017-03-17T17:34:21, null, null, null, null, [B@7ad2abce, null, null, [B@70d9cfb5, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, 0, null, null, null, null, null], after=[754, null, null, null, null, 1135886, 677159, 2017-03-17T17:34:21, null, null, null, null, [B@9013582, null, null, [B@3abf558d, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, 0, null, 18299, null, null, null]}
]}} (io.debezium.connector.mysql.BinlogReader:563)
[2017-03-17 20:17:20,192] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489755214000, eventType=QUERY, serverId=13, headerLength=19, dataLength=44, nextPosition=25557827, flags=8}, data=QueryEventData{threadId=223888, executionTime=158, errorCode=0, database='', sql='BEGIN'}} (io.debezium.connector.mysql.BinlogReader:422)
[2017-03-17 20:17:20,192] DEBUG Skipping update table metadata event: Event{header=EventHeaderV4{timestamp=1489755214000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=74, nextPosition=25557920, flags=0}, data=TableMapEventData{tableId=283857, database='NextServices', table='WORKING_DAYS_GROUP_CLASS_DEPT_MAPPING', columnTypes=8, 8, 8, 8, 3, 8, columnMetadata=0, 0, 0, 0, 0, 0, columnNullability={5}}} (io.debezium.connector.mysql.BinlogReader:477)
[2017-03-17 20:17:20,194] DEBUG Skipping insert row event: Event{header=EventHeaderV4{timestamp=1489755214000, eventType=EXT_WRITE_ROWS, serverId=13, headerLength=19, dataLength=61, nextPosition=25558000, flags=0}, data=WriteRowsEventData{tableId=283857, includedColumns={0, 1, 2, 3, 4, 5}, rows=[
    [762, 2160, 1135886, 12489, 1, 236]
]}} (io.debezium.connector.mysql.BinlogReader:519)
[2017-03-17 20:17:20,195] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489755223000, eventType=QUERY, serverId=13, headerLength=19, dataLength=44, nextPosition=25558159, flags=8}, data=QueryEventData{threadId=246181, executionTime=149, errorCode=0, database='', sql='BEGIN'}} (io.debezium.connector.mysql.BinlogReader:422)
[2017-03-17 20:17:20,195] DEBUG Skipping update table metadata event: Event{header=EventHeaderV4{timestamp=1489755223000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=56, nextPosition=25558234, flags=0}, data=TableMapEventData{tableId=283936, database='NextErpQa', table='SESSIONS', columnTypes=8, 8, 8, 18, 18, 18, 8, 15, 15, 15, columnMetadata=0, 0, 0, 0, 0, 0, 0, 765, 765, 765, columnNullability={3, 4, 5, 9}}} (io.debezium.connector.mysql.BinlogReader:477)
[2017-03-17 20:17:20,196] DEBUG Skipping insert row event: Event{header=EventHeaderV4{timestamp=1489755223000, eventType=EXT_WRITE_ROWS, serverId=13, headerLength=19, dataLength=130, nextPosition=25558383, flags=0}, data=WriteRowsEventData{tableId=283936, includedColumns={0, 1, 2, 3, 4, 5, 6, 7, 8, 9}, rows=[
    [149787, 113393, 47236, 2017-03-17T18:23:28, null, null, 0, [B@729095fc, [B@1a152cd0, [B@7f8cbb9b]
]}} (io.debezium.connector.mysql.BinlogReader:519)
[2017-03-17 20:17:20,196] DEBUG Skipping update table metadata event: Event{header=EventHeaderV4{timestamp=1489755223000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=56, nextPosition=25558458, flags=0}, data=TableMapEventData{tableId=283936, database='NextErpQa', table='SESSIONS', columnTypes=8, 8, 8, 18, 18, 18, 8, 15, 15, 15, columnMetadata=0, 0, 0, 0, 0, 0, 0, 765, 765, 765, columnNullability={3, 4, 5, 9}}} (io.debezium.connector.mysql.BinlogReader:477)
[2017-03-17 20:17:20,197] DEBUG Skipping update row event: Event{header=EventHeaderV4{timestamp=1489755223000, eventType=EXT_UPDATE_ROWS, serverId=13, headerLength=19, dataLength=250, nextPosition=25558727, flags=0}, data=UpdateRowsEventData{tableId=283936, includedColumnsBeforeUpdate={0, 1, 2, 3, 4, 5, 6, 7, 8, 9}, includedColumns={0, 1, 2, 3, 4, 5, 6, 7, 8, 9}, rows=[
    {before=[149785, 113393, 47236, 2017-03-17T18:16:59, null, null, 0, [B@35a45a92, [B@43ed16af, [B@702dc1ae], after=[149785, 113393, 47236, 2017-03-17T18:16:59, null, 2017-03-17T18:23:28, 0, [B@6a67ec53, [B@7d004b47, [B@56736226]}
]}} (io.debezium.connector.mysql.BinlogReader:566)
[2017-03-17 20:17:20,197] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1489755289000, eventType=QUERY, serverId=13, headerLength=19, dataLength=205, nextPosition=25559047, flags=0}, data=QueryEventData{threadId=234204, executionTime=85, errorCode=0, database='NextErpQa', sql='ALTER TABLE `NextLibrary`.`LIB_HOLDING_TYPE` 
CHANGE COLUMN `LIB_HOLDING_TYPE_ID` `LIB_HOLDING_TYPE_ID` BIGINT(20) NOT NULL AUTO_INCREMENT'}} (io.debezium.connector.mysql.BinlogReader:422)
[2017-03-17 20:17:20,201] DEBUG Recorded DDL statements for database 'NextErpQa': ALTER TABLE `NextLibrary`.`LIB_HOLDING_TYPE` 
CHANGE COLUMN `LIB_HOLDING_TYPE_ID` `LIB_HOLDING_TYPE_ID` BIGINT(20) NOT NULL AUTO_INCREMENT (io.debezium.connector.mysql.BinlogReader:449)
[2017-03-17 20:17:20,324] ERROR Failed due to error: Error processing binlog event (io.debezium.connector.mysql.BinlogReader:143)
org.apache.kafka.connect.errors.ConnectException: No more content
	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164)
	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:142)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:326)
	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)
Caused by: java.util.NoSuchElementException: No more content
	at io.debezium.text.TokenStream.currentToken(TokenStream.java:1666)
	at io.debezium.text.TokenStream.nextPosition(TokenStream.java:550)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:293)
	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)
	... 5 more
[2017-03-17 20:17:20,328] INFO 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:331)
[2017-03-17 20:17:21,009] ERROR Task msri-connector-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142)
org.apache.kafka.connect.errors.ConnectException: No more content
	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164)
	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:142)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:326)
	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)
Caused by: java.util.NoSuchElementException: No more content
	at io.debezium.text.TokenStream.currentToken(TokenStream.java:1666)
	at io.debezium.text.TokenStream.nextPosition(TokenStream.java:550)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:293)
	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)
	... 5 more
[2017-03-17 20:17:21,010] ERROR Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:143)