Conduktor
conduktor.io ↗
Conduktor
conduktor.io ↗
Extracted configuration properties for the Debezium SQL Server connector across versions 2.4–3.7. Cells highlighted in green are additions, red are removals, yellow are default changes.
| Property | Description | 2.4 | 2.5 | 2.6 | 2.7 | 3.0 | 3.1 | 3.2 | 3.3 | 3.4 | 3.5 | 3.6 | 3.7 |
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| binary.handling.mode | Specify how binary (blob, binary, etc.) columns should be represented in change events, including: 'bytes' represents bi.. | bytes | bytes | bytes | bytes | bytes | bytes | bytes | bytes | bytes | bytes | bytes | bytes |
| column.exclude.list | Regular expressions matching columns to exclude from change events | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| column.include.list | Regular expressions matching columns to include in change events | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| column.propagate.source.type | A comma-separated list of regular expressions matching fully-qualified names of columns that adds the column’s original .. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| converters | Optional list of custom converters that would be used instead of default ones. The converters are defined using '<conver.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| custom.metric.tags | A comma-separated list of key-value pairs that are appended to the MBean object name. Keys must be valid JMX ObjectName .. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| database.dbname | The name of the database from which the connector should capture changes | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| database.hostname | Resolvable hostname or IP address of the database server. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| database.names | The names of the databases from which the connector should capture changes | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| database.password | Password of the database user to be used when connecting to the database. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| database.port | Port of the database server. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| database.user | Name of the database user to be used when connecting to the database. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| datatype.propagate.source.type | A comma-separated list of regular expressions matching the database-specific data type names that adds the data type's o.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| decimal.handling.mode | Specify how DECIMAL and NUMERIC columns should be represented in change events, including: 'precise' (the default) uses .. | precise | precise | precise | precise | precise | precise | precise | precise | precise | precise | precise | precise |
| errors.max.retries | The maximum number of retries on connection errors before failing (-1 = no limit, 0 = disabled, > 0 = num of retries). | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| event.processing.failure.handling.mode | Specify how failures during processing of events (i.e. when encountering a corrupted event) should be handled, including.. | fail | fail | fail | fail | fail | fail | fail | fail | fail | fail | fail | fail |
| field.name.adjustment.mode | Specify how field names should be adjusted for compatibility with the message converter used by the connector, including.. | none | none | none | none | none | none | none | none | none | none | none | none |
| include.schema.changes | Whether the connector should publish changes in the database schema to a Kafka topic with the same name as the database .. | true | true | true | true | true | true | true | true | true | true | true | true |
| include.schema.comments | Whether the connector parse table and column's comment to metadata object. Note: Enable this option will bring the impli.. | false | false | false | false | false | false | false | false | false | false | false | false |
| incremental.snapshot.allow.schema.changes | Detect schema change during an incremental snapshot and re-select a current chunk to avoid locking DDLs. Note that chang.. | false | false | false | false | false | false | false | false | false | unresolved | unresolved | unresolved |
| incremental.snapshot.chunk.size | The maximum size of chunk (number of documents/rows) for incremental snapshotting | 1024 | 1024 | 1024 | 1024 | 1024 | 1024 | 1024 | 1024 | 1024 | 1024 | 1024 | 1024 |
| incremental.snapshot.option.recompile | Add OPTION(RECOMPILE) on each SELECT statement during the incremental snapshot process. This prevents parameter sniffing.. | false | false | false | false | false | false | false | false | false | false | false | false |
| max.batch.size | Maximum size of each batch of source records. Defaults to . | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| max.queue.size | Maximum size of the queue for change events read from the database log but not yet recorded or forwarded. Defaults to , .. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| max.queue.size.in.bytes | Maximum size of the queue in bytes for change events read from the database log but not yet recorded or forwarded. Defau.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| message.key.columns | A semicolon-separated list of expressions that match fully-qualified tables and column(s) to be used as message key. Eac.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| notification.enabled.channels | List of notification channels names that are enabled. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| poll.interval.ms | Time to wait for new change events to appear after receiving no events, given in milliseconds. Defaults to %d ms. Values.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| provide.transaction.metadata | Enables transaction metadata extraction together with event counting | false | false | false | false | false | false | false | false | false | unresolved | unresolved | unresolved |
| query.fetch.size | The maximum number of records that should be loaded into memory while streaming. A value of '0' uses the default JDBC fe.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| retriable.restart.connector.wait.ms | Time to wait before restarting connector after retriable exception occurs. Defaults to ms. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| schema.name.adjustment.mode | Specify how schema names should be adjusted for compatibility with the message converter used by the connector, includin.. | none | none | none | none | none | none | none | none | none | none | none | none |
| signal.data.collection | The name of the data collection that is used to send signals/commands to Debezium. For multi-partition mode connectors, .. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| signal.enabled.channels | List of channels names that are enabled. Source channel is enabled by default | source | source | source | source | source | source | source | source | source | source | source | source |
| signal.poll.interval.ms | Interval for looking for new signals in registered channels, given in milliseconds. Defaults to 5 seconds. | 5000 | 5000 | 5000 | 5000 | 5000 | 5000 | 5000 | 5000 | 5000 | 5000 | 5000 | 5000 |
| skip.messages.without.change | Enable to skip publishing messages when there is no change in included columns.This would essentially filter messages to.. | false | false | false | false | false | false | false | false | false | false | false | false |
| skipped.operations | The comma-separated list of operations to skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd.. | t | t | t | t | t | t | t | t | t | t | t | t |
| snapshot.delay.ms | A delay period before a snapshot will begin, given in milliseconds. Defaults to 0 ms. | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 |
| snapshot.fetch.size | The maximum number of records that should be loaded into memory while performing a snapshot. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| snapshot.include.collection.list | This setting must be set to specify a list of tables/collections whose snapshot must be taken on creating or restarting .. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| snapshot.isolation.mode | Controls which transaction isolation level is used and how long the connector locks the captured tables. The default is .. | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read | repeatable_read |
| snapshot.lock.timeout.ms | The maximum number of millis to wait for table locks at the beginning of a snapshot. If locks cannot be acquired in this.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| snapshot.max.threads | The maximum number of threads used to perform the snapshot. Defaults to 1. | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |
| snapshot.mode | Controls startup snapshots. Supported modes at v3.7.0.Final: always, initial, initial_only, no_data, recovery, when_need.. | initial | initial | initial | initial | initial | initial | initial | initial | initial | initial | initial | initial |
| snapshot.select.statement.overrides | This property contains a comma-separated list of fully-qualified tables (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME).. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| snapshot.tables.order.by.row.count | Controls the order in which tables are processed in the initial snapshot. A `descending` value will order the tables by .. | disabled | disabled | disabled | disabled | disabled | disabled | disabled | disabled | disabled | disabled | disabled | disabled |
| sourceinfo.struct.maker | The name of the SourceInfoStructMaker class that returns SourceInfo schema and struct. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| table.ignore.builtin | Flag specifying whether built-in tables should be ignored. | true | true | true | true | true | true | true | true | true | true | true | true |
| time.precision.mode | Time, date, and timestamps can be represented with different kinds of precisions, including: 'adaptive' (the default) ba.. | adaptive | adaptive | adaptive | adaptive | adaptive | adaptive | adaptive | adaptive | adaptive | unresolved | unresolved | unresolved |
| tombstones.on.delete | Whether delete operations should be represented by a delete event and a subsequent tombstone event (true) or only by a d.. | true | true | true | true | true | true | true | true | true | true | true | true |
| topic.naming.strategy | The name of the TopicNamingStrategy class that should be used to determine the topic name for data change, schema change.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| topic.prefix | Topic prefix that identifies and provides a namespace for the particular database server/cluster is capturing changes. T.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| unavailable.value.placeholder | Specify the constant that will be provided by Debezium to indicate that the original value is unavailable and not provid.. | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| incremental.snapshot.watermarking.strategy | Specify the strategy used for watermarking during an incremental snapshot: 'insert_insert' both open and close signal is.. | — | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT | INSERT_INSERT |
| post.processors | Optional list of post processors. The processors are defined using '<post.processor.prefix>.type' config option and conf.. | — | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| data.query.mode | Controls how the connector queries CDC data. The default is '', which makes the connector to query the change tables dir.. | — | — | function | function | function | function | function | function | direct | direct | direct | direct |
| event.converting.failure.handling.mode | Specify how failures during converting of event should be handled, including: 'fail' throw an exception that the column .. | — | — | warn | warn | warn | warn | warn | warn | warn | warn | warn | warn |
| snapshot.locking.mode | Controls how the connector holds locks on tables while performing the schema snapshot when `snapshot.isolation.mode` is .. | — | — | exclusive | exclusive | exclusive | exclusive | exclusive | exclusive | exclusive | exclusive | exclusive | exclusive |
| snapshot.locking.mode.custom.name | When 'snapshot.locking.mode' is set as custom, this setting must be set to specify a the name of the custom implementati.. | — | — | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| snapshot.mode.configuration.based.snapshot.data | When 'snapshot.mode' is set as configuration_based, this setting permits to specify whenever the data should be snapshot.. | — | — | false | false | false | false | false | false | false | false | false | false |
| snapshot.mode.configuration.based.snapshot.on.data.error | When 'snapshot.mode' is set as configuration_based, this setting permits to specify whenever the data should be snapshot.. | — | — | false | false | false | false | false | false | false | false | false | false |
| snapshot.mode.configuration.based.snapshot.on.schema.error | When 'snapshot.mode' is set as configuration_based, this setting permits to specify whenever the schema should be snapsh.. | — | — | false | false | false | false | false | false | false | false | false | false |
| snapshot.mode.configuration.based.snapshot.schema | When 'snapshot.mode' is set as configuration_based, this setting permits to specify whenever the schema should be snapsh.. | — | — | false | false | false | false | false | false | false | false | false | false |
| snapshot.mode.configuration.based.start.stream | When 'snapshot.mode' is set as configuration_based, this setting permits to specify whenever the stream should start or .. | — | — | false | false | false | false | false | false | false | false | false | false |
| snapshot.mode.custom.name | When 'snapshot.mode' is set as custom, this setting must be set to specify a the name of the custom implementation provi.. | — | — | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| snapshot.query.mode | Controls query used during the snapshot | — | — | select_all | select_all | select_all | select_all | select_all | select_all | select_all | select_all | select_all | select_all |
| snapshot.query.mode.custom.name | When 'snapshot.query.mode' is set as custom, this setting must be set to specify a the name of the custom implementation.. | — | — | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | not declared | not declared | not declared |
| database.query.timeout.ms | Time to wait for a query to execute, given in milliseconds. Defaults to 600 seconds (600,000 ms); zero means there is no.. | — | — | — | 600000 | 600000 | 600000 | 600000 | 600000 | 600000 | 600000 | 600000 | 600000 |
| streaming.delay.ms | A delay period after the snapshot is completed and the streaming begins, given in milliseconds. Defaults to 0 ms. | — | — | — | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 |
| transaction.metadata.factory | Class to make transaction context & transaction struct/schemas | — | — | — | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| streaming.fetch.size | Specifies the maximum number of rows that should be read in one go from each table while streaming. The connector will r.. | — | — | — | — | — | 0 | 0 | 0 | 0 | 0 | 0 | 0 |
| connection.validation.timeout.ms | The maximum time in milliseconds to wait for connection validation to complete. Defaults to 60 seconds. | — | — | — | — | — | — | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| executor.shutdown.timeout.ms | The maximum time in milliseconds to wait for task executor to shut down. | — | — | — | — | — | — | unknown (legacy extraction) | unknown (legacy extraction) | unknown (legacy extraction) | unresolved | unresolved | unresolved |
| guardrail.collections.limit.action | Specify the action to take when a guardrail collections limit is exceeded: 'warn' (the default) logs a warning message a.. | — | — | — | — | — | — | — | warn | warn | warn | warn | warn |
| guardrail.collections.max | The maximum number of collections or tables that can be captured by the connector. When this limit is exceeded, the acti.. | — | — | — | — | — | — | — | 0 | 0 | 0 | 0 | 0 |
| snapshot.max.threads.multiplier | The factor used to scale the number of snapshot chunks per table. The default behavior is to take 'row_count/snapshot.ma.. | — | — | — | — | — | — | — | — | — | 1 | 1 | 1 |
| legacy.snapshot.max.threads | When enabled, uses the legacy table-per-thread parallel snapshot algorithm. When set to false (the default), tables are .. | — | — | — | — | — | — | — | — | — | — | false | false |
| queue.provider.type | The name of the queue provider implementation to use for buffering change events. Defaults to '' which uses an in-memory.. | — | — | — | — | — | — | — | — | — | — | unresolved | unresolved |
| statistics.metrics.enabled | Enable to collect various kind of statistics, like latencies in record processing, and derived data like quantiles. By d.. | — | — | — | — | — | — | — | — | — | — | true | true |
| poll.dispatch.interval.ms | Time to accumulate change events in the queue between subsequent polls. Defaults to 0 ms. | — | — | — | — | — | — | — | — | — | — | — | unresolved |
| signal.emit.failure.backoff.ms | Duration to sleep for after encountering an error emitting a window event, given in milliseconds. Defaults to 10 seconds.. | — | — | — | — | — | — | — | — | — | — | — | 10000 |
| signal.emit.failure.max.retries | The maximum number of retries after encountering an error emitting a window event (-1 = no limit, 0 = disabled, > 0 = nu.. | — | — | — | — | — | — | — | — | — | — | — | 0 |
| tasks.max | Maximum number of tasks this connector can run. | — | — | — | — | — | — | — | — | — | — | — | not declared |