Hundiendo datos de temas del productor de Java a Mongodb

Tariq - No soy un experto en este tema. Pero he intentado algo similar con el adaptador receptor JDBC con la base de datos Oracle.

El formato de datos que le estás enviando al tema no me parece correcto. Por lo tanto, es posible que esté recibiendo el error. Dado que está utilizando JsonConverter, cada fila del tema debe tener el siguiente formato para que el adaptador receptor analice y escriba en un almacén de datos. Actualmente, sus datos no tienen un esquema en la carga útil. De ahí el error.

Pase lo siguiente al tema y vea si se hunde en 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
    }
}