Saya memecahkan kesalahan ini dengan membuat perubahan berikut
- insert.mode=insert
- Komentar table.name.format=kafkatable karena tabel akan dibuat melalui autocreate
- Hapus tanda tanya dari akhir baris connection.url.
- bidang pk.tidak boleh disimpan di sini, pastikan untuk memberikan nama kolom untuk menghindari komplikasi.
- int32 tidak didukung oleh postgresql, jadi ketika saya mengubahnya ke int8 berfungsi dengan baik.
- Bidang dalam skema dan payload Anda memiliki nama yang berbeda, pastikan untuk memberikan nama yang sama.
