2019-09-19 19:56:39,354 DEBUG MySQL|dptestSupersetEmployees|binlog Clearing table converters [io.debezium.connector.mysql.RecordMakers] 2019-09-19 19:56:39,355 DEBUG MySQL|dptestSupersetEmployees|binlog Received query command: Event{header=EventHeaderV4{timestamp=1568921902000, eventType=QUERY, serverId=876637055, headerLength=19, dataLength=57, nextPosition=11761, flags=8}, data=QueryEventData{threadId=2, executionTime=0, errorCode=0, database='', sql='BEGIN'}} [io.debezium.connector.mysql.BinlogReader] 2019-09-19 19:56:39,355 DEBUG MySQL|dptestSupersetEmployees|binlog Received query command: Event{header=EventHeaderV4{timestamp=1568921902000, eventType=QUERY, serverId=876637055, headerLength=19, dataLength=111, nextPosition=11891, flags=0}, data=QueryEventData{threadId=2, executionTime=0, errorCode=0, database='', sql='DELETE FROM mysql.rds_sysinfo where name = 'innodb_txn_key''}} [io.debezium.connector.mysql.BinlogReader] 2019-09-19 19:56:39,355 ERROR MySQL|dptestSupersetEmployees|binlog Error during binlog processing. Last offset stored = null, binlog reader near position = mysql-bin-changelog.022924/11761 [io.debezium.connector.mysql.BinlogReader] 2019-09-19 19:56:39,355 ERROR MySQL|dptestSupersetEmployees|binlog Failed due to error: Error processing binlog event [io.debezium.connector.mysql.BinlogReader] org.apache.kafka.connect.errors.ConnectException: Received DML 'DELETE FROM mysql.rds_sysinfo where name = 'innodb_txn_key'' for processing, binlog probably contains events generated with statement or mixed based replication format at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:523) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.kafka.connect.errors.ConnectException: Received DML 'DELETE FROM mysql.rds_sysinfo where name = 'innodb_txn_key'' for processing, binlog probably contains events generated with statement or mixed based replication format at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:709) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:507) ... 5 more 2019-09-19 19:56:39,356 INFO MySQL|dptestSupersetEmployees|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] 2019-09-19 19:56:39,682 INFO || WorkerSourceTask{id=dbtest-superset-employees-flat-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2019-09-19 19:56:39,682 INFO || WorkerSourceTask{id=dbtest-superset-employees-flat-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2019-09-19 19:56:39,682 DEBUG || WorkerSourceTask{id=dbtest-superset-employees-flat-0} Finished offset commitOffsets successfully in 0 ms [org.apache.kafka.connect.runtime.WorkerSourceTask] 2019-09-19 19:56:39,682 ERROR || WorkerSourceTask{id=dbtest-superset-employees-flat-0} Task threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException: Received DML 'DELETE FROM mysql.rds_sysinfo where name = 'innodb_txn_key'' for processing, binlog probably contains events generated with statement or mixed based replication format at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:523) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.kafka.connect.errors.ConnectException: Received DML 'DELETE FROM mysql.rds_sysinfo where name = 'innodb_txn_key'' for processing, binlog probably contains events generated with statement or mixed based replication format at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:709) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:507) ... 5 more 2019-09-19 19:56:39,683 ERROR || WorkerSourceTask{id=dbtest-superset-employees-flat-0} Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask]