Resolví este error haciendo los siguientes cambios
- insertar.modo=insertar
- Comenta table.name.format=kafkatable porque la tabla se creará a través de creación automática
- Elimine el signo de interrogación del final de la línea connection.url.
- pk.fields no debe mantenerse ninguno aquí, asegúrese de proporcionar un nombre de columna en su lugar para evitar complicaciones.
- int32 no es compatible con postgresql, por lo que cuando lo cambié a int8 funciona bien.
- Los campos en su esquema y carga útil tienen nombres diferentes, asegúrese de dar el mismo nombre.
