Ich habe diesen Fehler behoben, indem ich die folgenden Änderungen vorgenommen habe
- insert.mode=einfügen
- Kommentieren Sie table.name.format=kafkable aus, da die Tabelle automatisch erstellt wird
- Entfernen Sie das Fragezeichen vom Ende der Zeile connection.url.
- pk.fields sollten hier nicht beibehalten werden, bitte geben Sie stattdessen einen Spaltennamen an, um Komplikationen zu vermeiden.
- int32 wird von postgresql nicht unterstützt, also funktioniert es gut, wenn ich es in int8 geändert habe.
- Die Felder in Ihrem Schema und Ihrer Payload haben unterschiedliche Namen, bitte stellen Sie sicher, dass Sie denselben Namen angeben.
