Debezium

name=dbz_dw

slot.name=dbz_dw

connector.class=io.debezium.connector.postgresql.PostgresConnector

database.dbname=dw

database.user=postgres_ro

tasks.max=1

database.server.name=dbz_dw

database.port=5432

plugin.name=pgoutput

table.whitelist=bank,currency,request

internal.key.converter=org.apache.kafka.connect.json.JsonConverter

value.converter.schema.registry.url=http://schema-registry-cp-schema-registry:8081

database.sslmode=disable

database.hostname=dw-api-rds-dev-1.cq1ivvhcnwjt.ap-southeast-1.rds.amazonaws.com

database.password=V8BZYV-bFDKvaCtsDkj=slfnBvykBRAk)18BKIAd

internal.value.converter=org.apache.kafka.connect.json.JsonConverter

value.converter=io.confluent.connect.avro.AvroConverter

name=dbz_accounts

connector.class=io.debezium.connector.postgresql.PostgresConnector

slot.name=dbz_accounts

database.dbname=accounts

database.user=postgres_ro

tasks.max=1

database.server.name=dbz_accounts

database.port=5432

plugin.name=pgoutput

table.whitelist=roles

internal.key.converter=org.apache.kafka.connect.json.JsonConverter

value.converter.schema.registry.url=http://schema-registry-cp-schema-registry:8081

database.sslmode=disable

database.hostname=account-api-rds-dev-1.cq1ivvhcnwjt.ap-southeast-1.rds.amazonaws.com

database.password=Wl8?4TvPE^EGPb+uxf$sPPH!ew&SLYIA?C7mpNhXN

name=porkchop_jdbc

connector.class=io.confluent.connect.jdbc.JdbcSourceConnector

dialect.name=PostgreSqlDatabaseDialect

connection.password=V8BZYV-bFDKvaCtsDkj=slfnBvykBRAk)18BKIAd

validate.non.null=false

tasks.max=1

table.whitelist=bank

mode=bulk

topic.prefix=porkchop_jdbc_

connection.user=postgres_ro

connection.url=jdbc:postgresql://dw-api-rds-dev-1.cq1ivvhcnwjt.ap-southeast-1.rds.amazonaws.com:5432/dw

value.converter=org.apache.kafka.connect.json.JsonConverter

key.converter=org.apache.kafka.connect.json.JsonConverter

quote.sql.identifiers=never

Debezium Behavior

• If you add "table.whitelist". It does not create topics

• When I removed the "table.whitelist". It creates few topics

• "slot.name" must be unique.