Kafka Connect逻辑删除消息不应用InsertField转换

问题描述

InsertField转换未应用于逻辑删除消息中。

我正在使用postgres 10.1 / debezium 1.2.1版本/ kafka 2.4.1版本

例如。

• 配置

{
...
    "transforms": "InsertField","transforms.InsertField.type": "org.apache.kafka.connect.transforms.InsertField$Key","transforms.InsertField.static.field": "__host","transforms.InsertField.static.value": "abc.com",...
}

• 插入

key - {"id":1,"__host": "abc.com"},value - {"id":1,"__host": "abc.com","col1": 1,"col2": "a"}

• 删除（逻辑删除消息不适用于InsertField转换）

key - {"id":1,"__host": "abc.com"} value - {"id":1,"col1": null,"col2": null}
key - {"id":1} value - null

为什么会发生？是虫子吗？还是我错了？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）