Kafka Connect：用于有条件地替换字段值的SMT
Kafka Connect: SMT for conditional replacement of field values
我知道有一些转换操作可用，例如 MaskField 来屏蔽字段值。我有一个要求，我需要在其中进行条件屏蔽，即仅当同一字段具有特定值时才将值设置为 NULL。例如：
IF field_1 == 'HELLO' THEN
SET field_1 = null
ELSE
NO TRANSFORM
目前没有任何 SMT 支持字段值的条件替换。
但是，您可以按照 here 所述编写自己的单一消息转换。
我知道有一些转换操作可用，例如 MaskField 来屏蔽字段值。我有一个要求，我需要在其中进行条件屏蔽，即仅当同一字段具有特定值时才将值设置为 NULL。例如：
IF field_1 == 'HELLO' THEN
SET field_1 = null
ELSE
NO TRANSFORM
目前没有任何 SMT 支持字段值的条件替换。
但是，您可以按照 here 所述编写自己的单一消息转换。