source_connector_moma_postgres_kafka.json

{
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
    "database.hostname": "<your_database_hostname>",
    "database.port": "5432",
    "database.user": "<your_username>",
    "database.password": "<your_password>",
    "database.dbname": "moma",
    "database.server.name": "moma",
    "table.include.list": "public.artists,public.artworks",
    "plugin.name": "pgoutput",
    "key.converter": "io.apicurio.registry.utils.converter.AvroConverter",
    "key.converter.apicurio.registry.url": "http://localhost:8080/apis/registry/v2",
    "key.converter.apicurio.registry.auto-register": "true",
    "key.converter.apicurio.registry.find-latest": "true",
    "value.converter": "io.apicurio.registry.utils.converter.AvroConverter",
    "value.converter.apicurio.registry.url": "http://localhost:8080/apis/registry/v2",
    "value.converter.apicurio.registry.auto-register": "true",
    "value.converter.apicurio.registry.find-latest": "true",
    "transforms": "unwrap",
    "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
    "transforms.unwrap.drop.tombstones": "false",
    "transforms.unwrap.delete.handling.mode": "rewrite",
    "transforms.unwrap.add.fields": "op,db,table,schema,lsn,source.ts_ms"
}