Affondamento dei dati sull'argomento dal produttore Java a Mongodb

Tariq - Non sono un esperto in questo argomento. Ma ho provato una cosa simile con l'adattatore sink JDBC con database Oracle.

Il formato dei dati che stai inviando all'argomento non mi sembra corretto. Quindi, potresti ricevere l'errore. Poiché si utilizza JsonConverter, ogni riga nell'argomento deve essere nel formato seguente affinché l'adattatore sink possa analizzare e scrivere in un archivio dati. Attualmente i dati non hanno uno schema nel payload. Da qui l'errore.

Si prega di passare quanto segue all'argomento e vedere se affonda in MongoDB.

{
    "schema": {
        "type": "struct",
        "fields": [
            {
                "type": "string",
                "optional": false,
                "field": "name"
            },
            {
                "type": "string",
                "optional": true,
                "field": "dept"
            },
            {
                "type": "int64",
                "optional": true,
                "field": "studentId"
            }
        ],
        "optional": false,
        "name": "YOUR_TABLE_NAME"
    },
    "payload": {
        "name": "This is a test",
        "dept": "siqdj",
        "studentId": 1
    }
}