Sinken von Themendaten vom Java-Produzenten zu Mongodb

Tariq – Ich bin kein Experte auf diesem Gebiet. Aber ich habe etwas Ähnliches mit dem JDBC-Senkenadapter mit der Oracle-Datenbank versucht.

Das Datenformat, das Sie zum Thema senden, scheint mir nicht richtig zu sein. Daher erhalten Sie möglicherweise den Fehler. Da Sie den JsonConverter verwenden, sollte jede Zeile im Thema das folgende Format haben, damit der Senkenadapter sie analysieren und in einen Datenspeicher schreiben kann. Derzeit haben Ihre Daten kein Schema in der Nutzlast. Daher der Fehler.

Bitte leiten Sie das Folgende an das Thema weiter und sehen Sie, ob es zu MongoDB sinkt.

{
    "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
    }
}