Zinkende onderwerpgegevens van Java-producent naar Mongodb

Tariq - Ik ben geen expert in dit onderwerp. Maar ik heb iets soortgelijks geprobeerd met de JDBC-sink-adapter met Oracle-database.

Het gegevensformaat dat u naar het onderwerp stuurt, lijkt me niet juist. Daarom krijgt u mogelijk de fout. Aangezien u de JsonConverter gebruikt, moet elke rij in het onderwerp de volgende indeling hebben zodat de sink-adapter kan worden geparseerd en naar een gegevensarchief kan worden geschreven. Momenteel hebben uw gegevens geen schema in de payload. Vandaar de fout.

Geef het onderstaande door aan het onderwerp en kijk of het zinkt naar 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
    }
}