Eu resolvi esse erro fazendo as seguintes alterações
- inserir.mode=inserir
- Comente o table.name.format=kafkatable porque a tabela será criada por meio da criação automática
- Remova o ponto de interrogação do final da linha connection.url.
- pk.fields não deve ser mantido nenhum aqui, certifique-se de fornecer um nome de coluna para evitar complicações.
- int32 não é suportado pelo postgresql, então quando mudei para int8 está funcionando bem.
- Os campos em seu esquema e carga útil têm nomes diferentes, certifique-se de dar o mesmo nome.
