Afundando dados de tópicos do produtor Java para o Mongodb

Tariq - Não sou especialista nesse assunto. Mas eu tentei uma coisa semelhante com o adaptador de coletor JDBC com banco de dados Oracle.

O formato de dados que você está enviando para o tópico não me parece correto. Portanto, você pode estar recebendo o erro. Como você está usando o JsonConverter, cada linha no tópico deve estar no formato a seguir para que o adaptador do coletor analise e grave em um armazenamento de dados. Atualmente, seus dados não têm esquema na carga útil. Daí o erro.

Por favor, passe o abaixo para o tópico e veja se ele afunda no 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
    }
}