Sjunkande ämnesdata från Java-producent till Mongodb

Tariq - Jag är ingen expert på detta ämne. Men jag har provat en liknande sak med JDBC sink-adapter med Oracle-databas.

Dataformatet du skickar till ämnet verkar inte vara rätt för mig. Därför kan du få felet. Eftersom du använder JsonConverter, bör varje rad i ämnet vara i följande format för att sinkadaptern ska kunna analysera och skriva till ett datalager. För närvarande har dina data inget schema i nyttolasten. Därav felet.

Vänligen skicka nedanstående till ämnet och se om det sjunker till 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
    }
}