MongoDB Kafka Sink Connector verwerkt de RenameByRegex-processor niet

Ik denk dat alles wat je wilt is Kafka Connect Single Message Transform (SMT) en meer precies ReplaceField :

Het volgende vervangt id veldnaam met _id :

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

In uw geval, voordat u de bovenstaande transformatie toepast, wilt u misschien ook Flatten foos :

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

en pas ten slotte de transformatie toe voor het hernoemen van het veld:

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