我认为您想要的只是 ReplaceField :

I think all you want is Kafka Connect Single Message Transform (SMT) and more precisely ReplaceField:

过滤或重命名Struct或Map中的字段.

Filter or rename fields within a Struct or Map.

以下内容将 id 字段名称替换为 _id :

"transforms": "RenameField",
"transforms.RenameField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.RenameField.renames": "id:_id"

以您为例，在应用上述转换之前，您可能还想 Flatten foos :

"transforms": "flatten",
"transforms.flatten.type": "org.apache.kafka.connect.transforms.Flatten$Value",
"transforms.flatten.delimiter": "."

，最后将转换应用于字段重命名:

and finally apply the transformation for renaming the field:

"transforms": "RenameField",
"transforms.RenameField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.RenameField.renames": "foos.id:foos._id"