1

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, "__host": "abc.com", "col1": null, "col2": null}
key - {"id":1} value - null

なぜそれが起こったのですか？バグですか？または私は間違っていますか？

4

1 に答える 1