Tuto chybu jsem vyřešil provedením následujících změn
- insert.mode=insert
- Okomentujte table.name.format=kafkatable, protože tabulka bude vytvořena pomocí automatického vytváření
- Odstraňte otazník z konce řádku connection.url.
- pk.fields by zde neměly být ponechány žádné, nezapomeňte místo toho zadat název sloupce, abyste předešli komplikacím.
- int32 není podporován postgresql, takže když jsem jej změnil na int8, funguje dobře.
- Pole ve vašem schématu a datové části mají různé názvy, nezapomeňte zadat stejný název.