'Debezium mySql connecter not able to capture insert and updater operation

I am trying to implemnt CDC piline with Debezium mysql connecter and kafkal But Source connecter not able to pusblish event for insert and update operation in table... Schema changes are reflecting in kafka Topic

i have check bin log is ebabled

here are my Source connecter configuration

    "name": "user_source_v6",
    "config": {
        "connector.class": "io.debezium.connector.mysql.MySqlConnector",
        "tasks.max": "1",
        "database.hostname": "host....",
        "database.port": "3306",
        "database.user": "test",
        "database.password": "test",
        "database.server.id": "119",
        "database.server.name": "dbserver19",
        "database.whitelist": "crowdsource",
        "database.history.kafka.topic": "user_source_v6",
        "database.history.kafka.bootstrap.servers": "host...:9092",
        "database.history.store.only.monitored.tables.ddl": "true"
    }
}
mysqlapache-kafkaapache-kafka-connectdebeziumcdc


Solution 1:[1]

The behavior is observed when CDC on database/table is enabled to capture limited operations.

Re-enable CDC on the table with all operations enabled. (C,U,D)

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source
Solution 1 Suchandra Tungare

Related Questions