Kafka Connect: SMT для условной замены значений полей

Question

Я знаю, что доступны действия преобразования, например MaskField для маскировки значений полей. У меня есть требование, когда мне нужно сделать условную маскировку, т.е. установить значение на NULL, только если в том же поле задано значение c. Например:

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

Answer 1

В настоящее время нет ни одного SMT, поддерживающего условную замену значения поля.

---

Однако вы можете написать собственное преобразование одного сообщения, как описано здесь .