Zatapianie danych tematycznych od producenta Javy do Mongodb

Tariq - nie jestem ekspertem w tym temacie. Ale próbowałem podobnej rzeczy z adapterem do zlewu JDBC z bazą danych Oracle.

Format danych, który wysyłasz do tematu, wydaje mi się nieodpowiedni. W związku z tym możesz otrzymać błąd. Ponieważ używasz JsonConverter, każdy wiersz w temacie powinien mieć następujący format, aby adapter ujścia mógł analizować i zapisywać w magazynie danych.Obecnie dane nie mają schematu w ładunku. Stąd błąd.

Przekaż poniższe informacje do tematu i sprawdź, czy trafia do 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
    }
}