Konektor Sink MongoDB Kafka tidak memproses prosesor RenameByRegex

Saya rasa yang Anda inginkan hanyalah Kafka Connect Single Message Transform (SMT) dan lebih tepatnya ReplaceField :

Berikut ini akan menggantikan id nama bidang dengan _id :

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

Dalam kasus Anda, sebelum menerapkan transformasi di atas, Anda mungkin juga ingin Flatten foos :

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

dan akhirnya terapkan transformasi untuk mengganti nama bidang:

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