Push Data fra Kafka Topic til PostgreSQL i JSON

Jeg løste denne fejl ved at foretage følgende ændringer

1. insert.mode=insert
2. Kommenter table.name.format=kafkatable, fordi tabellen vil blive oprettet via autocreate
3. Fjern spørgsmålstegnet fra slutningen af ​​connection.url-linjen.
4. pk.fields bør ikke opbevares her, sørg venligst for at give et kolonnenavn i stedet for at undgå komplikationer.
5. int32 understøttes ikke af postgresql, så da jeg ændrede det til int8, fungerer det fint.
6. Felterne i dit skema og din nyttelast har forskellige navne. Sørg for at give samme navn.