Details
-
Bug
-
Resolution: Unresolved
-
Major
-
None
-
0.9.5.Final
-
None
Description
Table is listed to DROP but DDL never gets created and then errors when it finds a record on the binlog - please see below:
2019-09-02 13:30:50,802 INFO MySQL|dbserver8|snapshot Step 6: generating DROP and CREATE statements to reflect current database schemas: [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,032 INFO MySQL|dbserver8|snapshot SET character_set_server=utf8mb4, collation_server=utf8mb4_general_ci; [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,108 INFO MySQL|dbserver8|snapshot DROP TABLE IF EXISTS `xxxx`.`agentlog` [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,116 INFO MySQL|dbserver8|snapshot DROP TABLE IF EXISTS `xxxx`.`calls` [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,121 INFO MySQL|dbserver8|snapshot DROP TABLE IF EXISTS `xxxx`.`engine.ecl` [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,136 INFO MySQL|dbserver8|snapshot DROP DATABASE IF EXISTS `xxxx` [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,144 INFO MySQL|dbserver8|snapshot CREATE DATABASE `xxxx` [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,152 INFO MySQL|dbserver8|snapshot USE `xxxx` [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,408 WARN MySQL|dbserver8|snapshot Column is missing a character set: ProgramID CHAR(20) NOT NULL DEFAULT VALUE [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,408 WARN MySQL|dbserver8|snapshot Using UTF-8 charset by default for column without charset: ProgramID CHAR(20) NOT NULL DEFAULT VALUE [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,421 INFO MySQL|dbserver8|snapshot CREATE TABLE `agentlog` (
`AgentID` varchar(50) NOT NULL,
`EventTime` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
`Skill` varchar(256) DEFAULT NULL,
`EventType` varchar(50) NOT NULL,
`EngineID` char(20) NOT NULL,
`CallID` varchar(50) DEFAULT NULL,
`AgentLogId` bigint(20) NOT NULL AUTO_INCREMENT,
`ProgramID` char(20) NOT NULL DEFAULT '',
`LastUpdateTime` datetime(3) DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3),
`CallGuid` varchar(64) DEFAULT NULL,
`SegmentID` varchar(50) DEFAULT NULL,
`GeneralInfo` varchar(256) DEFAULT NULL,
`InstanceID` varchar(50) DEFAULT NULL,
`InteractionType` varchar(20) DEFAULT NULL,
PRIMARY KEY (`AgentLogId`,`EventTime`),
KEY `IX_EngineAgentLog_EventTime` (`EventTime`),
KEY `IX_EngineAgentLog_ProgramID_EventTime` (`ProgramID`,`EventTime`)
) ENGINE=InnoDB AUTO_INCREMENT=1117317246 DEFAULT CHARSET=latin1
/*!50100 PARTITION BY RANGE (to_days(`EventTime`))
(PARTITION pmin VALUES LESS THAN (736420) ENGINE = InnoDB,
PARTITION p201604 VALUES LESS THAN (736450) ENGINE = InnoDB,
PARTITION p201605 VALUES LESS THAN (736481) ENGINE = InnoDB,
PARTITION p201606 VALUES LESS THAN (736511) ENGINE = InnoDB,
PARTITION p201607 VALUES LESS THAN (736542) ENGINE = InnoDB,
PARTITION p201608 VALUES LESS THAN (736573) ENGINE = InnoDB,
PARTITION p201609 VALUES LESS THAN (736603) ENGINE = InnoDB,
PARTITION p201610 VALUES LESS THAN (736634) ENGINE = InnoDB,
PARTITION p201611 VALUES LESS THAN (736664) ENGINE = InnoDB,
PARTITION p201612 VALUES LESS THAN (736695) ENGINE = InnoDB,
PARTITION p201701 VALUES LESS THAN (736726) ENGINE = InnoDB,
PARTITION p201702 VALUES LESS THAN (736754) ENGINE = InnoDB,
PARTITION p201703 VALUES LESS THAN (736785) ENGINE = InnoDB,
PARTITION p201704 VALUES LESS THAN (736815) ENGINE = InnoDB,
PARTITION p201705 VALUES LESS THAN (736846) ENGINE = InnoDB,
PARTITION p201706 VALUES LESS THAN (736876) ENGINE = InnoDB,
PARTITION p201707 VALUES LESS THAN (736907) ENGINE = InnoDB,
PARTITION p201708 VALUES LESS THAN (736938) ENGINE = InnoDB,
PARTITION p201709 VALUES LESS THAN (736968) ENGINE = InnoDB,
PARTITION p201710 VALUES LESS THAN (736999) ENGINE = InnoDB,
PARTITION p201711 VALUES LESS THAN (737029) ENGINE = InnoDB,
PARTITION p201712 VALUES LESS THAN (737060) ENGINE = InnoDB,
PARTITION p201801 VALUES LESS THAN (737091) ENGINE = InnoDB,
PARTITION p201802 VALUES LESS THAN (737119) ENGINE = InnoDB,
PARTITION p201803 VALUES LESS THAN (737150) ENGINE = InnoDB,
PARTITION p201804 VALUES LESS THAN (737180) ENGINE = InnoDB,
PARTITION p201805 VALUES LESS THAN (737211) ENGINE = InnoDB,
PARTITION p201806 VALUES LESS THAN (737241) ENGINE = InnoDB,
PARTITION p201807 VALUES LESS THAN (737272) ENGINE = InnoDB,
PARTITION p201808 VALUES LESS THAN (737303) ENGINE = InnoDB,
PARTITION p201809 VALUES LESS THAN (737333) ENGINE = InnoDB,
PARTITION p201810 VALUES LESS THAN (737364) ENGINE = InnoDB,
PARTITION p201811 VALUES LESS THAN (737394) ENGINE = InnoDB,
PARTITION p201812 VALUES LESS THAN (737425) ENGINE = InnoDB,
PARTITION p201901 VALUES LESS THAN (737456) ENGINE = InnoDB,
PARTITION p201902 VALUES LESS THAN (737484) ENGINE = InnoDB,
PARTITION p201903 VALUES LESS THAN (737515) ENGINE = InnoDB,
PARTITION p201904 VALUES LESS THAN (737545) ENGINE = InnoDB,
PARTITION p201905 VALUES LESS THAN (737576) ENGINE = InnoDB,
PARTITION p201906 VALUES LESS THAN (737606) ENGINE = InnoDB,
PARTITION p201907 VALUES LESS THAN (737637) ENGINE = InnoDB,
PARTITION p201908 VALUES LESS THAN (737668) ENGINE = InnoDB,
PARTITION p201909 VALUES LESS THAN (737698) ENGINE = InnoDB,
PARTITION p201910 VALUES LESS THAN (737729) ENGINE = InnoDB,
PARTITION p201911 VALUES LESS THAN (737759) ENGINE = InnoDB,
PARTITION p201912 VALUES LESS THAN (737790) ENGINE = InnoDB,
PARTITION p202001 VALUES LESS THAN (737821) ENGINE = InnoDB,
PARTITION p202002 VALUES LESS THAN (737850) ENGINE = InnoDB,
PARTITION p202003 VALUES LESS THAN (737881) ENGINE = InnoDB,
PARTITION p202004 VALUES LESS THAN (737911) ENGINE = InnoDB,
PARTITION p202005 VALUES LESS THAN (737942) ENGINE = InnoDB,
PARTITION p202006 VALUES LESS THAN (737972) ENGINE = InnoDB,
PARTITION p202007 VALUES LESS THAN (738003) ENGINE = InnoDB) */ [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,588 WARN || [Producer clientId=producer-4] Error while fetching metadata with correlation id 3 :
[org.apache.kafka.clients.NetworkClient]
2019-09-02 13:30:52,634 INFO MySQL|dbserver8|snapshot CREATE TABLE `calls` (
`id` bigint(20) NOT NULL,
`cli` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
`start_time` timestamp NULL DEFAULT NULL,
`end_time` timestamp NULL DEFAULT NULL,
`queue_id` int(11) NOT NULL,
`client_id` int(11) NOT NULL,
`agent_id` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:52,877 WARN MySQL|dbserver8|snapshot Column is missing a character set: ProgramID CHAR(20) NOT NULL DEFAULT VALUE [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,878 WARN MySQL|dbserver8|snapshot Using UTF-8 charset by default for column without charset: ProgramID CHAR(20) NOT NULL DEFAULT VALUE [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,879 WARN MySQL|dbserver8|snapshot Column is missing a character set: MultiCall CHAR(2) NOT NULL DEFAULT VALUE [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,879 WARN MySQL|dbserver8|snapshot Using UTF-8 charset by default for column without charset: MultiCall CHAR(2) NOT NULL DEFAULT VALUE [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,880 WARN MySQL|dbserver8|snapshot Column is missing a character set: CallType VARCHAR(10) NOT NULL DEFAULT VALUE EXTERNAL [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,880 WARN MySQL|dbserver8|snapshot Using UTF-8 charset by default for column without charset: CallType VARCHAR(10) NOT NULL DEFAULT VALUE EXTERNAL [io.debezium.connector.mysql.MySqlValueConverters]
2019-09-02 13:30:52,902 INFO MySQL|dbserver8|snapshot Step 7: releasing global read lock to enable MySQL writes [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:53,102 INFO MySQL|dbserver8|snapshot Step 7: blocked writes to MySQL for a total of 00:00:03.322 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:53,104 INFO MySQL|dbserver8|snapshot Step 8: scanning contents of 3 tables while still in transaction [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:53,386 INFO MySQL|dbserver8|snapshot Step 8: - scanning table 'xxxx.agentlog' (1 of 3 tables) [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:53,386 INFO MySQL|dbserver8|snapshot For table 'xxxx.agentlog' using select statement: 'SELECT * FROM `xxxx`.`agentlog`' [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:53,484 INFO MySQL|dbserver8|snapshot Step 8: - Completed scanning a total of 0 rows from table 'xxxx.agentlog' after 00:00:00.098 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:53,759 INFO MySQL|dbserver8|snapshot Step 8: - scanning table 'xxxx.calls' (2 of 3 tables) [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:53,759 INFO MySQL|dbserver8|snapshot For table 'xxxx.calls' using select statement: 'SELECT * FROM `xxxx`.`calls`' [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:54,035 WARN || [Producer clientId=producer-4] Error while fetching metadata with correlation id 7 :
[org.apache.kafka.clients.NetworkClient]
2019-09-02 13:30:54,663 INFO MySQL|dbserver8|snapshot Step 8: - 10000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:00.903 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:55,168 INFO MySQL|dbserver8|snapshot Step 8: - 20000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:01.409 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:30:57,716 INFO MySQL|dbserver8|snapshot Step 8: - 30000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:03.956 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:00,192 INFO MySQL|dbserver8|snapshot Step 8: - 40000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:06.433 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:02,592 INFO MySQL|dbserver8|snapshot Step 8: - 50000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:08.832 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:04,688 INFO MySQL|dbserver8|snapshot Step 8: - 60000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:10.928 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:06,747 INFO MySQL|dbserver8|snapshot Step 8: - 70000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:12.987 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:08,392 INFO MySQL|dbserver8|snapshot Step 8: - 80000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:14.633 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:10,376 INFO MySQL|dbserver8|snapshot Step 8: - 90000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:16.616 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:12,324 INFO MySQL|dbserver8|snapshot Step 8: - 100000 of 105155 rows scanned from table 'xxxx.calls' after 00:00:18.565 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:13,483 INFO MySQL|dbserver8|snapshot Step 8: - Completed scanning a total of 105304 rows from table 'xxxx.calls' after 00:00:19.723 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:13,605 INFO MySQL|dbserver8|snapshot Step 8: scanned 105304 rows in 3 tables in 00:00:20.499 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:13,605 INFO MySQL|dbserver8|snapshot Step 9: committing transaction [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:13,699 INFO MySQL|dbserver8|snapshot Completed snapshot in 00:00:24.624 [io.debezium.connector.mysql.SnapshotReader]
2019-09-02 13:31:15,236 INFO MySQL|dbserver8|task Transitioning from the snapshot reader to the binlog reader [io.debezium.connector.mysql.ChainedReader]
2019-09-02 13:31:16,093 INFO MySQL|dbserver8|task Creating thread debezium-mysqlconnector-dbserver8-binlog-client [io.debezium.util.Threads]
2019-09-02 13:31:16,187 INFO MySQL|dbserver8|task Creating thread debezium-mysqlconnector-dbserver8-binlog-client [io.debezium.util.Threads]
Sep 02, 2019 1:31:16 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
INFO: Connected to 10.32.250.252:3306 at binlog.000041/716206303 (sid:184054, cid:282)
2019-09-02 13:31:16,830 INFO MySQL|dbserver8|binlog Connected to MySQL binlog at 10.32.250.252:3306, starting at binlog file 'binlog.000041', pos=716206303, skipping 0 events plus 0 rows [io.debezium.connector.mysql.BinlogReader]
2019-09-02 13:31:16,832 INFO MySQL|dbserver8|binlog Creating thread debezium-mysqlconnector-dbserver8-binlog-client [io.debezium.util.Threads]
2019-09-02 13:31:47,233 INFO || WorkerSourceTask
2019-09-02 13:31:47,237 INFO || WorkerSourceTask{id=etq-connector8-0}
flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
2019-09-02 13:31:47,263 INFO || WorkerSourceTask
2019-09-02 13:32:47,263 INFO || WorkerSourceTask{id=etq-connector8-0}
Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
2019-09-02 13:32:47,264 INFO || WorkerSourceTask
2019-09-02 13:33:28,322 ERROR MySQL|dbserver8|binlog Encountered change event 'Event{header=EventHeaderV4{timestamp=1567431201000, eventType=TABLE_MAP, serverId=1, headerLength=19, dataLength=247, nextPosition=716206734, flags=0}, data=TableMapEventData{tableId=614, database='xxxx', table='engine.ecl', columnTypes=15, 3, 3, 15, 15, 15, 15, 18, 18, 18, 18, 18, 15, 15, 3, 3, 3, 15, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 3, 3, -2, 1, 15, 15, 15, 15, 18, 15, 15, 15, 15, -2, 3, 15, 15, -2, 18, 15, 15, 1, 15, 4, 15, 15, 15, 3, 15, 15, 15, 18, 15, 4, 4, 3, 15, 15, 15, 18, 18, 15, 18, 15, 15, 15, 15, 15, 15, 15, 15, 15, 15, columnMetadata=50, 0, 0, 50, 256, 256, 140, 3, 3, 3, 3, 3, 50, 50, 0, 0, 0, 4000, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 0, 0, 65044, 0, 8000, 50, 50, 50, 3, 3, 4000, 50, 8000, 65044, 0, 256, 256, 65026, 3, 50, 10, 0, 50, 4, 50, 200, 50, 0, 64, 50, 200, 3, 50, 4, 4, 0, 50, 1024, 50, 3, 3, 50, 3, 200, 1000, 1000, 8000, 50, 8000, 50, 20, 50, 2000, columnNullability={3, 4, 5, 6, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 42, 43, 44, 47, 49, 50, 51, 52, 53, 54, 55, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80}, eventMetadata=TableMapEventMetadata{signedness={}, defaultCharset=8, charsetCollations=null, columnCharsets=null, columnNames=null, setStrValues=null, enumStrValues=null, geometryTypes=null, simplePrimaryKeys=null, primaryKeysWithPrefix=null, enumAndSetDefaultCharset=null, enumAndSetColumnCharsets=null}}}' at offset {ts_sec=1567431201, file=binlog.000041, pos=716206388, server_id=1, event=1} for table xxxx.engine.ecl whose schema isn't known to this connector. One possible cause is an incomplete database history topic. Take a new snapshot in this case.
Use the mysqlbinlog tool to view the problematic event: mysqlbinlog --start-position=716206468 --stop-position=716206734 --verbose binlog.000041 [io.debezium.connector.mysql.BinlogReader]
2019-09-02 13:33:28,325 ERROR MySQL|dbserver8|binlog Error during binlog processing. Last offset stored = null, binlog reader near position = binlog.000041/716206468 [io.debezium.connector.mysql.BinlogReader]
2019-09-02 13:33:28,326 ERROR MySQL|dbserver8|binlog Failed due to error: Error processing binlog event [io.debezium.connector.mysql.BinlogReader]
org.apache.kafka.connect.errors.ConnectException: Encountered change event for table xxxx.engine.eclwhose schema isn't known to this connector
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:508)
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: Encountered change event for table xxxx.engine.eclwhose schema isn't known to this connector
at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:758)
at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:733)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
... 5 more
2019-09-02 13:33:28,329 INFO MySQL|dbserver8|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-02 13:33:28,529 INFO || WorkerSourceTask{id=etq-connector8-0}
Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
2019-09-02 13:33:28,531 INFO || WorkerSourceTask
2019-09-02 13:33:28,531 ERROR || WorkerSourceTask{id=etq-connector8-0}
Task threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: Encountered change event for table xxxx.engine.eclwhose schema isn't known to this connector
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:508)
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: Encountered change event for table xxxx.engine.eclwhose schema isn't known to this connector
at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:758)
at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:733)
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
... 5 more
2019-09-02 13:33:28,531 ERROR || WorkerSourceTask
Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask]
2019-09-02 13:33:28,532 INFO MySQL|dbserver8|task Stopping MySQL connector task [io.debezium.connector.mysql.MySqlConnectorTask]
2019-09-02 13:33:28,532 INFO MySQL|dbserver8|task ChainedReader: Stopping the binlog reader [io.debezium.connector.mysql.ChainedReader]
2019-09-02 13:33:28,532 INFO MySQL|dbserver8|task Discarding 0 unsent record(s) due to the connector shutting down [io.debezium.connector.mysql.BinlogReader]
2019-09-02 13:33:28,536 INFO MySQL|dbserver8|task Discarding 0 unsent record(s) due to the connector shutting down [io.debezium.connector.mysql.BinlogReader]
2019-09-02 13:33:28,537 INFO MySQL|dbserver8|task [Producer clientId=etq-connector8-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. [org.apache.kafka.clients.producer.KafkaProducer]