apache-kafka - 如何使用 kafka connect Transforms 屏蔽/删除 JSON 列

Question

我正在使用 Kafka debizium MySQL 连接器，我正在尝试使用转换删除/屏蔽 json 列，

尝试了掩码字段，但它不起作用

transforms: "maskField",
transforms.maskField.type: "org.apache.kafka.connect.transforms.MaskField$Value",
transforms.maskField.fields: "data",

original :

{
  "id": "10001",
  "data": {
    "key1": "value1",
    "key2": "value2"
  }
}

expected :

{
  "id": "10001",
  "data": null
}

or 

{
  "id": "10001"
}

我怎样才能做到这一点，使用转换？

Answer 1

还有这种方式：

“变换”：“替换字段”，

"transforms.ReplaceField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",

“transforms.ReplaceField.blacklist”：“field_name_here”

我不确定 %100 但你可以试一试。