-
Feature Request
-
Resolution: Duplicate
-
Optional
-
None
-
0.8.2.Final
-
None
We have added one table for some time in MySQL Debezium and then we tried adding more tables in whitelist parameter and the following error while updating the connector using PUT API:
org.apache.kafka.connect.errors.ConnectException: Encountered change event for table whose schema isn't known to this connector at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:200) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:178) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:452) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1055) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:913) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:559) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:793) at java.lang.Thread.run(Thread.java:748)\nCaused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table whose schema isn't known to this connector at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:700) at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:676) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:436) ... 5 more
Now, what we want is that connector starts reading from current binlog position with the all whitelisted tables.
Any Help? jpechane gunnar.morling
- is related to
-
DBZ-683 SnapshotReader should honor database.history.store.only.monitored.tables.ddl
- Closed