Как выполнить маскирование с помощью пользовательских или случайных значений в исходном соединителе apache kafka, а затем снять маску с сообщения в соединителе приемника kafka?

Question

{
transforms=SSNMask,IPMask,PhoneMask 
transforms.SSNMask.type=org.apache.kafka.connect.transforms.MaskField$Value
transforms.SSNMask.fields=ssn
}

преобразования должны иметь некоторые дополнительные свойства для использования пользовательских значений или случайных значений вместо нулевых значений.