次の変更を加えることでこのエラーを解決しました
- insert.mode =insert
- テーブルは自動作成によって作成されるため、table.name.format=kafkatableをコメントアウトします
- connection.url行の末尾から疑問符を削除します。
- pk.fieldsはここに何も保持しないでください。複雑さを避けるために、代わりに列名を付けてください。
- int32はpostgresqlでサポートされていないため、int8に変更すると正常に機能します。
- スキーマとペイロードのフィールドの名前は異なります。必ず同じ名前を付けてください。