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

Question

我知道有一些转换动作，例如 MaskField 来屏蔽字段值。我有一个需求，我需要做条件屏蔽，即设置值为 NULL 只有当同一字段有特定的值时，才会使用。例如，我知道有一些转换操作，例如MaskField来掩盖字段的值。

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

Answer 1

目前没有任何SMT支持对字段值进行有条件的替换。

---

然而，你可以写你自己的单消息转换，如描述的那样。此处.