Naprawiłem ten błąd, wprowadzając następujące zmiany
- insert.mode=insert
- Skomentuj table.name.format=kafkatable, ponieważ tabela zostanie utworzona przez automatyczne tworzenie
- Usuń znak zapytania z końca linii connection.url.
- pk.fields nie powinny być tutaj zachowywane. Pamiętaj, aby zamiast tego podać nazwę kolumny, aby uniknąć komplikacji.
- int32 nie jest obsługiwany przez postgresql, więc kiedy zmieniłem go na int8, działa dobrze.
- Pola w schemacie i ładunku mają różne nazwy, pamiętaj, aby podać tę samą nazwę.
