Synker emnedata fra Java-producent til Mongodb

Tariq - Jeg er ingen ekspert i dette emne. Men jeg har prøvet en lignende ting med JDBC sink-adapter med Oracle-database.

Det dataformat, du sender til emnet, virker ikke rigtigt for mig. Derfor får du muligvis fejlen. Da du bruger JsonConverter, skal hver række i emnet være i følgende format for at sink-adapteren kan parse og skrive til et datalager. I øjeblikket har dine data ikke et skema i nyttelasten. Derfor fejlen.

Send venligst nedenstående til emnet og se, om det synker til 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
    }
}