sql >> データベース >  >> NoSQL >> MongoDB

MongoDB KafkaSinkConnectorはRenameByRegexプロセッサを処理しません

    必要なのは Kafka Connect Single Message Transform(SMT) だけだと思います より正確には、 ReplaceField

    以下はidを置き換えます _idを含むフィールド名 :

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

    あなたの場合、上記の変換を適用する前に、 Flatten foos

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

    最後に、フィールドの名前を変更するための変換を適用します。

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



    1. ClusterControlを使用したMongoDB4.0の監視と運用管理

    2. mongoDB:$unwindを元に戻す方法

    3. ExpressJSおよびNodeJSのMongooseからの応答オブジェクトのキーの並べ替え

    4. NoSQL/MongoDbとデータ/モデルの構造についてアドバイスが必要です