【问题标题】:Deleting Records in database through kafka jdbc connector通过kafka jdbc连接器删除数据库中的记录
【发布时间】:2019-05-20 22:55:37
【问题描述】:

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

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

【问题讨论】:

    标签: mysql apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect


    【解决方案1】:

    【讨论】:

    • 感谢 cricket_007。那么,有没有其他方法可以处理删除?
    • 除了获取此 PR 并自己构建代码吗?或者编写自己的单独消费者来监听可为空的记录值?我不知道
    猜你喜欢
    • 1970-01-01
    • 2016-11-28
    • 2020-06-19
    • 1970-01-01
    • 1970-01-01
    • 2018-07-29
    • 2014-07-11
    • 2020-01-12
    • 2018-05-01
    相关资源
    最近更新 更多