Potopení dat tématu od producenta Java do Mongodb

Tariq - Nejsem odborník na toto téma. Ale zkusil jsem podobnou věc s JDBC sink adaptérem s databází Oracle.

Formát dat, který posíláte do tématu, se mi nezdá správný. Může se tedy stát, že se vám zobrazí chyba. Vzhledem k tomu, že používáte JsonConverter, každý řádek v tématu by měl být v následujícím formátu, aby jej adaptér dřezu mohl analyzovat a zapisovat do úložiště dat. Vaše data v současné době nemají schéma v datové části. Proto ta chyba.

Předejte prosím níže uvedené téma k tématu a zjistěte, zda se ponoří do 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
    }
}