sql >> Databasteknik >  >> RDS >> PostgreSQL

Skicka data från Kafka Topic till PostgreSQL i JSON

Jag löste det här felet genom att göra följande ändringar

  1. insert.mode=insert
  2. Kommentera ut table.name.format=kafkatable eftersom tabellen kommer att skapas genom autocreate
  3. Ta bort frågetecknet från slutet av connection.url-raden.
  4. pk.fields ska inte behållas här, se till att ange ett kolumnnamn istället för att undvika komplikationer.
  5. int32 stöds inte av postgresql, så när jag ändrade det till int8 fungerar det bra.
  6. Fälten i ditt schema och nyttolast har olika namn, se till att ge samma namn.


  1. Hur man får skillnaden mellan två datum avrundad till timmar

  2. Lösenordsautentisering misslyckas med komplext lösenord

  3. Hur kan jag bygga en sqlite-tabell från denna xml/txt-fil med python?

  4. Hur tar jag bort en av mina två dubbletter av data i Postgres?