-
Task
-
Resolution: Done
-
Major
-
1.0.0.Final
-
None
The Debezium MySQL connector captures the DDLs into the topic mentioned in the "database.history.kafka.topic" setting. However, the row level changes like insert,delete, update are not appearing in Kafka. It has not created topics for any table. I have attached a document that contains the settings MySQL database and the debezium-mysql connector definition.
I am running Kafka 2.4 ( kafka_2.12-2.4.0.tgz) on Windows 10.
Here are all the topics in the Kafka broker.
%KAFKA_HOME%\bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092
__consumer_offsets
connect-configs
connect-offsets
connect-status
dbhistory.fullfillment
mysql
sql>SHOW GRANTS;
- Grants for dbz@%
'GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON . TO \'dbz\'@\'%\''
The inventory table in the database named "MySQL" contains 2 records.
USE mysql;
SELECT *
FROM mysql.inventory;
id, item, creation_date
0, One, 2020-01-11
0, Two, 2020-01-11