JavaプロデューサーからMongodbへのトピックデータのシンク

Tariq-私はこのトピックの専門家ではありません。しかし、私はOracleデータベースを備えたJDBCシンクアダプタで同様のことを試みました。

あなたがトピックに送信しているデータ形式は私には正しくないようです。したがって、エラーが発生している可能性があります。 JsonConverterを使用しているため、シンクアダプターが解析してデータストアに書き込むには、トピックの各行が次の形式である必要があります。現在、データのペイロードにはスキーマがありません。したがって、エラーです。

以下をトピックに渡して、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
    }
}