pgoutput Debezium Plugin

Giriş

Açıklaması şöyle

The pgoutput Debezium plugin is a Kafka Connect connector that can be used to capture changes from a PostgreSQL database and stream them to Kafka. The plugin uses the pgoutput replication stream to capture changes, which is a high-performance way to capture changes from PostgreSQL.

Varsayılan çıktı avro formatında

Örnek

Şöyle yaparız

curl -H 'Content-Type: application/json' debezium:8083/connectors --data '
{
  "name": "shipments-connector",  
  "config": {
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector", 
    "plugin.name": "pgoutput",
    "database.hostname": "postgres", 
    "database.port": "5432", 
    "database.user": "postgresuser", 
    "database.password": "postgrespw", 
    "database.dbname" : "shipment_db", 
    "database.server.name": "postgres", 
    "table.include.list": "public.shipments" 
  }
}'