MongoDB
 sql >> Baza danych >  >> NoSQL >> MongoDB

MongoDB Kafka Sink Connector nie przetwarza procesora RenameByRegex

Myślę, że wszystko, czego chcesz, to Kafka Connect Single Message Transform (SMT) a dokładniej ReplaceField :

Poniższe zastąpi id nazwa pola z _id :

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

W Twoim przypadku przed zastosowaniem powyższej transformacji możesz również chcieć Flatten foos :

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

i na koniec zastosuj transformację do zmiany nazwy pola:

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



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Nie można połączyć Robomongo za pomocą obrazu dokowanego MongoDB

  2. Ponowne używanie połączeń z bazą danych z Azure Functions przy użyciu JavaScript

  3. Sortowanie w MongoDB według elemMatch

  4. Dlaczego nie mogę znaleźć rekordu według _id in mongodb

  5. Włącz agregację zawierającą $cond do DBObject w java