Потъване на данни за теми от производителя на Java към Mongodb

Тарик - Не съм експерт в тази тема. Но аз опитах подобно нещо с JDBC адаптер за приемник с база данни на Oracle.

Форматът на данните, който изпращате в темата, не ми се струва правилен. Следователно може да получавате грешката. Тъй като използвате JsonConverter, всеки ред в темата трябва да бъде в следния формат, за да може адаптерът за приемник да анализира и записва в хранилище за данни. В момента вашите данни нямат схема в полезния товар. Оттук и грешката.

Моля, предайте по-долу към темата и вижте дали потъва в 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
    }
}