Debezium Connector Configuration Reference for Confluent Cloud

This topic describes the additional Debezium configuration properties that we plan to expose for the Debezium MySQL, PostgreSQL, and SQL Server v2 connectors.

We recommend removing these parameters (if they are in your existing configuration) to avoid potential connector behavior changes. Once the enhancement is complete, you can use the newly supported parameters based on your use case.

Common Debezium Configurations

  • column.include.list
  • skip.messages.without.change
  • column.propagate.source.type
  • message.key.columns-
  • binary.handling.mode
  • snapshot.include.collection.list
  • snapshot.lock.timeout.ms
  • max.batch.size
  • poll.interval.ms
  • snapshot.delay.ms
  • streaming.delay.ms
  • provide.transaction.metadata
  • skipped.operations
  • notification.enabled.channels
  • incremental.snapshot.watermarking.strategy
  • topic.heartbeat.prefix
  • topic.transaction
  • notification.sink.topic.name
  • column.truncate.to.length.chars
  • column.mask.with.length.chars
  • column.mask.hash.hashAlgorithm.with.salt.salt
  • column.mask.hash.v2.hashAlgorithm.with.salt.salt
  • snapshot.fetch.size
  • signal.enabled.channels
  • incremental.snapshot.chunk.size
  • snapshot.max.threads
  • database.query.timeout.ms
  • signal.kafka.groupId
  • signal.kafka.bootstrap.servers
  • signal.kafka.poll.timeout.ms

PostgreSQL (Debezium) Configurations

  • slot.drop.on.stop
  • schema.include.list
  • schema.exclude.list
  • hstore.handling.mode
  • interval.handling.mode
  • datatype.propagate.source.type
  • message.prefix.include.list
  • message.prefix.exclude.list
  • snapshot.isolation.mode
  • include.unknown.datatypes
  • status.update.interval.ms
  • schema.refresh.mode
  • slot.stream.params
  • slot.max.retries
  • slot.retry.delay.ms
  • unavailable.value.placeholder
  • xmin.fetch.interval.ms
  • database.sslcert
  • database.sslkey
  • database.sslpassword
  • database.sslrootcert
  • database.sslfactory
  • database.tcpKeepAlive
  • replica.identity.autoset.values
  • money.fraction.digits
  • database.initial.statements
  • read.only

MySQL (Debezium) Configurations

  • bigint.unsigned.handling.mode
  • connect.timeout.ms
  • database.exclude.list
  • gtid.source.excludes
  • gtid.source.includes
  • include.query
  • include.schema.changes
  • enable.time.adjuster
  • event.converting.failure.handling.mode
  • incremental.snapshot.allow.schema.changes
  • snapshot.tables.order.by.row.count
  • table.ignore.builtin
  • use.nongraceful.disconnect
  • schema.history.internal.kafka.query.timeout.ms
  • schema.history.internal.kafka.create.timeout.ms
  • schema.history.internal.store.only.captured.databases.ddl
  • database.initial.statements
  • database.ssl.keystore
  • database.ssl.keystore.password
  • database.ssl.truststore
  • database.ssl.truststore.password
  • read.only
  • driver.connectionTimeZone

Microsoft SQL Server CDC Source (Debezium) Configurations

  • schema.include.list
  • schema.exclude.list
  • include.schema.changes
  • datatype.propagate.source.type
  • incremental.snapshot.allow.schema.changes
  • max.iteration.transactions
  • schema.history.internal.kafka.query.timeout.ms
  • schema.history.internal.kafka.create.timeout.ms
  • schema.history.internal.store.only.captured.databases.ddl
  • query.fetch.size
  • max.iteration.transactions
  • incremental.snapshot.option.recompile
  • data.query.mode