Kafka connect configured properly but any records captured from MySQL table

Kafka Connect
1

Hi all,
I have started a new project recently. I have connected Kafka to MySQL via debezium.
But unfortunately, I can’t capture new records from the table.
I could get schema and server changes via separated topics but nothing from the table.
bin-log has been activated in MySQL as this debezium guidance explained.
All privileges have been granted in MySQL and show variables like '%bin%' shows log-bin is ON.
In the beginning, I thought the problem is about accessibility to the /var/log/mysql/ directory, which
may not allow MySQL access to logs, but didn’t work.
My connector log is working properly and shows no error, but the main problem still
remains. precisely, I can’t get any INSERT, UPDATE, and DELETE from the table.
What is the problem?
Connector configuration:

name=mysql-user2
connector.class=io.debezium.connector.mysql.MySqlConnector
database.hostname=***.**.**.**
database.port=3306
database.user=*******
database.password=*************
database.server.id=223344
database.server.name=Debezium2
database.include.list=kafka_test
table.include.list=user
database.history.kafka.bootstrap.servers=localhost:9092
database.history.kafka.topic=dbhistory.dbserver2
2

Problem was from the name of the table.include.list , so that should be table.include.list=kafka_test.user .

3

This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.