Search code examples
mysqlapache-kafkakafka-consumer-apikafka-producer-apiapache-kafka-connect

Deleting Records in database through kafka jdbc connector


I am trying to connect Kafka connector with database using confluent kafka jdbc connector.

I can do insert and update the records from one database to another, but when I try to delete the records, the deleted records are not reflecting into target db. I mean synchronization of records(deleted records) are not deleted from target database.


Solution

  • You won't be able to until this gets merged

    https://github.com/confluentinc/kafka-connect-jdbc/pull/282