MongoDB Kafka Sink Connector behandler ikke RenameByRegex-processoren

Jeg tror, ​​at alt, hvad du ønsker, er Kafka Connect Single Message Transform (SMT) og mere præcist ReplaceField :

Følgende erstatter id feltnavn med _id :

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

I dit tilfælde, før du anvender ovenstående transformation, vil du måske også Flatten foos :

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

og anvend til sidst transformationen for at omdøbe feltet:

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