Đang xóa dữ liệu chủ đề từ nhà sản xuất Java sang Mongodb

Tariq - Tôi không phải là chuyên gia trong chủ đề này. Nhưng tôi đã thử một điều tương tự với bộ điều hợp bồn rửa JDBC với cơ sở dữ liệu Oracle.

Định dạng dữ liệu bạn đang gửi cho chủ đề có vẻ không phù hợp với tôi. Do đó, bạn có thể gặp lỗi. Vì bạn đang sử dụng JsonConverter, mỗi hàng trong chủ đề phải ở định dạng sau để bộ điều hợp chìm có thể phân tích cú pháp và ghi vào kho dữ liệu. Hiện tại dữ liệu của bạn không có lược đồ trong tải trọng. Do đó, lỗi.

Vui lòng chuyển phần bên dưới cho chủ đề và xem nó có chìm vào MongoDB không.

{
    "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
    }
}