Ho risolto questo errore apportando le seguenti modifiche
- inserire.mode=inserire
- Commenta il table.name.format=kafkatable perché la tabella verrà creata tramite la creazione automatica
- Rimuovi il punto interrogativo dalla fine della riga connection.url.
- pk.fields non dovrebbe essere mantenuto qui, assicurati di fornire invece un nome di colonna per evitare complicazioni.
- int32 non è supportato da postgresql, quindi quando l'ho cambiato in int8 funziona correttamente.
- I campi nello schema e nel payload hanno nomi diversi, assicurati di dare lo stesso nome.
