Transfert des données de sujet du producteur Java vers Mongodb

Tariq - Je ne suis pas un expert dans ce domaine. Mais j'ai essayé une chose similaire avec l'adaptateur de récepteur JDBC avec la base de données Oracle.

Le format de données que vous envoyez au sujet ne me semble pas correct. Par conséquent, vous pouvez obtenir l'erreur. Étant donné que vous utilisez JsonConverter, chaque ligne de la rubrique doit être au format suivant pour que l'adaptateur de récepteur puisse analyser et écrire dans un magasin de données. Actuellement, vos données n'ont pas de schéma dans la charge utile. D'où l'erreur.

Veuillez transmettre le message ci-dessous au sujet et voir s'il est transmis à 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
    }
}