Kafka连接带有一个匿名转换来隐藏个人信息，然而，不是加密。对于匿名化，您可以使用名为“maskfield”的内置单消息转换（smt）（见下文）。加密还不可用，但您可以随时添加您的自定义smt与您选择的加密。
根据马斯克菲尔德的资料你可以用它来
使用字段类型的有效空值（如0、false、空字符串等）屏蔽指定的字段，或
使用replacement属性替换任何字符串或数字字段。
上述链接中还提供了配置的两种用法的示例：

# Mask Value

"transforms": "MaskField",
"transforms.MaskField.type": "org.apache.kafka.connect.transforms.MaskField$Value",
"transforms.MaskField.fields": "string_field"

# Replcae Value

"transforms": "SSNMask,IPMask,PhoneMask"

"transforms.SSNMask.type": "org.apache.kafka.connect.transforms.MaskField$Value"
"transforms.SSNMask.fields": "SSN"
"transforms.SSNMask.replacement": "***-***-****"

"transforms.IPMask.type": "org.apache.kafka.connect.transforms.MaskField$Value"
"transforms.IPMask.fields": "IPAddress"
"transforms.IPMask.replacement": "xxx.xxx.xxx.xxx"

"transforms.PhoneMask.type": "org.apache.kafka.connect.transforms.MaskField$Value"
"transforms.PhoneMask.fields": "office,mobile"
"transforms.PhoneMask.replacement": "+0-000-000-0000"