sql >> Database >  >> RDS >> PostgreSQL

Gegevens pushen van Kafka-onderwerp naar PostgreSQL in JSON

Ik heb deze fout opgelost door de volgende wijzigingen aan te brengen

  1. insert.mode=insert
  2. Reageer op table.name.format=kafkatable omdat de tabel wordt gemaakt via automatisch aanmaken
  3. Verwijder het vraagteken aan het einde van de regel connection.url.
  4. pk.fields mogen hier niet worden bewaard, zorg ervoor dat u in plaats daarvan een kolomnaam opgeeft om complicaties te voorkomen.
  5. int32 wordt niet ondersteund door postgresql, dus toen ik het veranderde in int8 werkte het prima.
  6. De velden in uw schema en payload hebben verschillende namen, zorg ervoor dat u dezelfde naam opgeeft.


  1. Forken of niet forken?

  2. Hoe maak je een installatieprogramma als je klaar bent met Java Desktop Application met MySQL DB?

  3. De huidige rowversion-waarde voor een SQL Server-database retourneren (T-SQL-voorbeeld)

  4. Selecteer terug dingen die niet bestaan