Tôi đã giải quyết lỗi này bằng cách thực hiện các thay đổi sau
- insert.mode =insert
- Nhận xét về table.name.format =kafkatable vì bảng sẽ được tạo thông qua tự động tạo
- Xóa dấu chấm hỏi khỏi dòng end of connect.url.
- không nên giữ các trường pk.fields ở đây, hãy đảm bảo đặt tên cột để tránh phức tạp.
- int32 không được postgresql hỗ trợ, vì vậy khi tôi đổi thành int8, nó vẫn hoạt động tốt.
- Các trường trong lược đồ và trọng tải của bạn có tên khác nhau, hãy đảm bảo đặt cùng tên.
