PostgreSQL
 sql >> Base de données >  >> RDS >> PostgreSQL

Transférer les données du sujet Kafka vers PostgreSQL dans JSON

J'ai résolu cette erreur en apportant les modifications suivantes

  1. insert.mode=insérer
  2. Commentez la table.name.format=kafkatable car la table sera créée via la création automatique
  3. Supprimez le point d'interrogation à la fin de la ligne connection.url.
  4. pk.fields ne doit pas être conservé ici, veuillez vous assurer de donner un nom de colonne à la place pour éviter les complications.
  5. int32 n'est pas pris en charge par postgresql, donc quand je l'ai changé en int8, cela fonctionne bien.
  6. Les champs de votre schéma et de votre charge utile ont des noms différents, veuillez vous assurer de donner le même nom.