Kafka连接:字段值条件替换的smt

jckbn6z7  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(280)

例如,我知道有一些转换操作可用 MaskField 屏蔽字段值。我有一个要求,我需要做条件掩蔽,即设置值为 NULL 仅当同一字段具有特定值时。例如:

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

kadbb4591#

目前没有任何smt支持有条件替换字段值。
但是,您可以编写自己的单个消息转换,如下所述。

相关问题