[2020-01-29 17:59:43,413] INFO WorkerSourceTask{id=source6-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [2020-01-29 17:59:43,413] INFO WorkerSourceTask{id=source6-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [2020-01-29 18:00:02,914] ERROR Error during binlog processing. Last offset stored = {ts_sec=1580303771, file=mysql-bin-changelog.231673, pos=5591402, row=1, server_id=1776619472, event=3}, binlog reader near position = mysql-bin-changelog.231730/196 (io.debezium.connector.mysql.BinlogReader) [2020-01-29 18:00:02,914] ERROR 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_monitor' 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:207) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:536) 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_monitor' for processing, binlog probably contains events generated with statement or mixed based replication format at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:721) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:519) ... 5 more [2020-01-29 18:00:02,915] 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) [2020-01-29 18:00:03,387] INFO WorkerSourceTask{id=source6-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [2020-01-29 18:00:03,388] INFO WorkerSourceTask{id=source6-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [2020-01-29 18:00:03,388] ERROR WorkerSourceTask{id=source6-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_monitor' 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:207) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:536) 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_monitor' for processing, binlog probably contains events generated with statement or mixed based replication format at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:721) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:519) ... 5 more [2020-01-29 18:00:03,388] ERROR WorkerSourceTask{id=source6-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask) [2020-01-29 18:00:03,388] INFO Stopping MySQL connector task (io.debezium.connector.mysql.MySqlConnectorTask) [2020-01-29 18:00:03,388] INFO ChainedReader: Stopping the binlog reader (io.debezium.connector.mysql.ChainedReader) [2020-01-29 18:00:03,388] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.BinlogReader) [2020-01-29 18:00:03,388] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.BinlogReader) [2020-01-29 18:00:03,388] INFO Stopped reading binlog after 12867225 events, last recorded offset: {ts_sec=1580303771, file=mysql-bin-changelog.231673, pos=5591402, row=1, server_id=1776619472, event=3} (io.debezium.connector.mysql.BinlogReader) [2020-01-29 18:00:03,388] INFO [Producer clientId=source6-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2020-01-29 18:00:03,390] INFO Connector task finished all work and is now shutdown (io.debezium.connector.mysql.MySqlConnectorTask) [2020-01-29 18:00:03,390] INFO [Producer clientId=producer-43] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2020-01-29 18:00:43,413] INFO WorkerSourceTask{id=source6-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [2020-01-29 18:00:43,413] INFO WorkerSourceTask{id=source6-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask)