Skip to content

Instantly share code, notes, and snippets.

@ponyjackal
Created February 6, 2024 00:31
Show Gist options
  • Save ponyjackal/afc7dd525cb8a5384ae5452f5c10800a to your computer and use it in GitHub Desktop.
Save ponyjackal/afc7dd525cb8a5384ae5452f5c10800a to your computer and use it in GitHub Desktop.
JDBC Postgres Sink Connector Config
{
"name": "newuser",
"connector.class": "io.debezium.connector.jdbc.JdbcSinkConnector",
"tasks.max": "1",
"connection.url": "jdbc:postgresql://${MASTER_DB_HOST}:${MASTER_DB_PORT}/${MASTER_DB_NAME}",
"connection.username": "${MASTER_DB_USER}",
"connection.password": "${MASTER_DB_PASSWORD}",
"insert.mode": "upsert",
"delete.enabled": "true",
"primary.key.mode": "record_key",
"primary.key.fields": "id",
"schema.evolution": "basic",
"auto.evolve": "true",
"database.time_zone": "UTC",
"topics": "user.public.user",
"table.name.format": "new_user",
"transforms": "filterFields",
"transforms.filterFields.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.filterFields.whitelist": "name,avatar"
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment