-
Bug
-
Resolution: Done
-
Major
-
0.10.0.Beta2
-
None
-
The connectors config I've used -
{ "snapshot.mode": "schema_only", "connector.class": "io.debezium.connector.mysql.MySqlConnector", "tasks.max": "1", "database.hostname": "<hostname>", "database.port": "3306", "database.user": "<user>", "database.password": "<pwd>", "database.server.id": "1", "database.server.name": "db", "database.whitelist": "starterview", "database.history.kafka.bootstrap.servers": "<broker>:9092", "database.history.kafka.topic": "schema-changes.general", "transforms":"changeTopic", "transforms.changeTopic.type":"org.apache.kafka.connect.transforms.RegexRouter", "transforms.changeTopic.regex":"db.(starterview|alerts)(.*)", "transforms.changeTopic.replacement":"aurora-tables","database.history.skip.unparseable.ddl": "true"}
{ "name": "debezium-aurora", "config":}
The connectors config I've used - { "name": "debezium-aurora", "config": { "snapshot.mode": "schema_only", "connector.class": "io.debezium.connector.mysql.MySqlConnector", "tasks.max": "1", "database.hostname": "<hostname>", "database.port": "3306", "database.user": "<user>", "database.password": "<pwd>", "database.server.id": "1", "database.server.name": "db", "database.whitelist": "starterview", "database.history.kafka.bootstrap.servers": "<broker>:9092", "database.history.kafka.topic": "schema-changes.general", "transforms":"changeTopic", "transforms.changeTopic.type":"org.apache.kafka.connect.transforms.RegexRouter", "transforms.changeTopic.regex":"db.(starterview|alerts)(.*)", "transforms.changeTopic.replacement":"aurora-tables","database.history.skip.unparseable.ddl": "true"} }
Upon creating a connector, Debezium tries to flush performance_schema.accounts table although the database.whitelist is filtering another schema. this fails on permissions -
org.apache.kafka.connect.errors.ConnectException: command denied to user '<username>'@'' for table 'accounts' Error code: 1142; SQLSTATE: 42000.
The error doesn't happen on 0.9.5.final
