通过 kafka jdbc 连接器删除数据库中的记录

Deleting Records in database through kafka jdbc connector

我正在尝试使用 confluent kafka jdbc 连接器将 Kafka 连接器与数据库连接起来。

我可以将记录从一个数据库插入和更新到另一个数据库,但是当我尝试删除记录时,删除的记录没有反映到目标数据库中。我的意思是记录的同步(删除的记录)不会从目标数据库中删除。

在合并之前您将无法使用

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