Myslím, že vše, co chcete, je Kafka Connect Single Message Transform (SMT)
a přesněji ReplaceField
:
Následující text nahradí id název pole s _id :
"transforms": "RenameField",
"transforms.RenameField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.RenameField.renames": "id:_id"
Ve vašem případě můžete před použitím výše uvedené transformace také chtít Flatten
foos :
"transforms": "flatten",
"transforms.flatten.type": "org.apache.kafka.connect.transforms.Flatten$Value",
"transforms.flatten.delimiter": "."
a nakonec použijte transformaci pro přejmenování pole:
"transforms": "RenameField",
"transforms.RenameField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.RenameField.renames": "foos.id:foos._id"