Kafka Connect：用于有条件替换字段值的 SMT

Question

我知道有可用的转换操作，例如 MaskField 来屏蔽字段值。我有一个要求，我需要进行条件屏蔽，即仅当同一字段具有特定值时才将值设置为 NULL。例如：

IF field_1 == 'HELLO' THEN
 SET field_1 = null
ELSE
 NO TRANSFORM

Answer 1

目前没有任何 SMT 支持有条件地替换字段值。

---

但是，您可以按照here 的描述编写自己的单消息转换。