[2019-09-06 04:53:15,593] INFO WorkerSourceTask{id=debezium-connector-mysql-tb-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
[2019-09-06 04:53:15,593] ERROR WorkerSourceTask{id=debezium-connector-mysql-tb-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
org.apache.kafka.connect.errors.ConnectException: Can not read response from server. Expected to read 15,054,484 bytes, read 3,624,253 bytes before connection was unexpectedly lost. Error code: 0; SQLSTATE: S1000.
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.SnapshotReader.execute(SnapshotReader.java:721)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.sql.SQLException: Can not read response from server. Expected to read 15,054,484 bytes, read 3,624,253 bytes before connection was unexpectedly lost.
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
at com.mysql.cj.jdbc.ConnectionImpl.commit(ConnectionImpl.java:813)
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:636)
... 3 more
[2019-09-06 04:53:15,593] ERROR WorkerSourceTask{id=debezium-connector-mysql-tb-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:180)
[2019-09-06 04:53:15,593] INFO Stopping MySQL connector task (io.debezium.connector.mysql.MySqlConnectorTask:430)
[2019-09-06 04:53:15,593] INFO ChainedReader: Stopping the snapshot reader (io.debezium.connector.mysql.ChainedReader:121)
[2019-09-06 04:53:15,593] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.SnapshotReader:129)
[2019-09-06 04:53:15,594] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.SnapshotReader:129)
[2019-09-06 04:53:15,594] INFO [Producer clientId=debezium-connector-mysql-tb-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1153)
[2019-09-06 04:53:15,597] INFO Connector task finished all work and is now shutdown (io.debezium.connector.mysql.MySqlConnectorTask:465)
[2019-09-06 04:53:15,597] ERROR Unable to unregister the MBean 'debezium.mysql:type=connector-metrics,context=snapshot,server=data_connector' (io.debezium.connector.mysql.SnapshotReader:81)
[2019-09-06 04:53:15,597] ERROR Unable to unregister the MBean 'debezium.mysql:type=connector-metrics,context=binlog,server=data_connector' (io.debezium.connector.mysql.BinlogReader:81)
[2019-09-06 04:53:15,597] INFO [Producer clientId=connector-producer-debezium-connector-mysql-tb-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1153)
[2019-09-06 04:53:22,669] INFO WorkerSourceTask{id=debezium-connector-mysql-tb-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
[2019-09-06 04:53:22,670] INFO WorkerSourceTask{id=debezium-connector-mysql-tb-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)