Details
-
Enhancement
-
Resolution: Done
-
Minor
-
0.3.1
-
None
Description
During the snapshot the Kafka topic receives events (confirmed using the console consumer). After the snapshot it seems like the connector is connected to the correct binlog file/pos (see log below) but no events show up on the same Kafka topic
2016-09-03 16:39:27,003 INFO MySQL|mysql-server-dbstg2|task Step 0: Get all known binlogs from MySQL [io.debezium.connector.mysql.MySqlConnectorTask] 2016-09-03 16:39:27,012 INFO MySQL|mysql-server-dbstg2|task MySQL has the binlog file 'dbstg2-20-bin-log.000097' required by the connector [io.debezium.connector.mysql.MySqlConnectorTask] Sep 03, 2016 4:39:27 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect INFO: Connected to 172.30.43.2:3306 at dbstg2-20-bin-log.000097/74864 (sid:20, cid:1169) 2016-09-03 16:39:27,085 INFO MySQL|mysql-server-dbstg2|binlog Connected to MySQL binlog at 172.30.43.2:3306, starting at binlog file 'dbstg2-20-bin-log.000097', pos=74864, row=0 [io.debezium.connector.mysql.BinlogReader] 2016-09-03 16:39:27,085 INFO || Source task WorkerSourceTask{id=optimis-staging-cc-0} finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask]