如何使用 gpkafka 更新和删除 greenplum 数据库中的数据？

【问题标题】：How to update and delete data in greenplum database using gpkafka?如何使用 gpkafka 更新和删除 greenplum 数据库中的数据？
【发布时间】：2019-06-19 17:13:22
【问题描述】：

我正在尝试使用 debezium、kafka 和 gpkafka 将数据从 mysql 复制到 greenplum。插入工作正常。但我无法更新和删除 greenplum 中的数据。请让我知道 gpkafka 实用程序是否支持更新和删除以及 gpkafka yaml 文件中需要什么配置。

【问题讨论】：

标签： mysql apache-kafka greenplum debezium

【解决方案1】：

我来自从事 gpKafka 工作的 Greenplum 团队。

到目前为止，两者都不支持。我们正在努力进行更新，很快就会推出。删除不在当前范围内。

【讨论】：

注意 Debezium 带有an SMT，它允许您将删除重写为“已删除”列的更新。这可用于删除在接收器端标记为已删除的记录，例如某种批处理作业。
谢谢，贡纳尔。软删除确实是一个很好的方法。我们会考虑并且应该能够支持它。