Menenggelamkan data topik dari produsen Java ke Mongodb

Tariq - Saya bukan ahli dalam topik ini. Tapi saya sudah mencoba hal serupa dengan adaptor sink JDBC dengan database Oracle.

Format data yang Anda kirim ke topik tampaknya tidak benar bagi saya. Karenanya, Anda mungkin mendapatkan kesalahan. Karena Anda menggunakan JsonConverter, setiap baris dalam topik harus dalam format berikut agar adaptor sink dapat diurai dan ditulis ke penyimpanan data. Saat ini data Anda tidak memiliki skema di payload. Karenanya kesalahannya.

Harap sampaikan topik di bawah ini dan lihat apakah topik tersebut tenggelam ke 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
    }
}