default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.additionalProperties(String key,
Object value) |
Additional properties for debezium components in case they can't be
set directly on the camel configurations (e.g: setting Kafka Connect
properties needed by Debezium engine, for example setting
KafkaOffsetBackingStore), the properties have to be prefixed with
additionalProperties..
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.additionalProperties(Map values) |
Additional properties for debezium components in case they can't be
set directly on the camel configurations (e.g: setting Kafka Connect
properties needed by Debezium engine, for example setting
KafkaOffsetBackingStore), the properties have to be prefixed with
additionalProperties..
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.AdvancedDebeziumPostgresEndpointBuilder.basic() |
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.binaryHandlingMode(String binaryHandlingMode) |
Specify how binary (blob, binary, etc.) columns should be represented
in change events, including:'bytes' represents binary data as byte
array (default)'base64' represents binary data as base64-encoded
string'hex' represents binary data as hex-encoded (base16) string.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.columnBlacklist(String columnBlacklist) |
Regular expressions matching columns to exclude from change events
(deprecated, use column.exclude.list instead).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.columnExcludeList(String columnExcludeList) |
Regular expressions matching columns to exclude from change events.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.columnIncludeList(String columnIncludeList) |
Regular expressions matching columns to include in change events.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.columnPropagateSourceType(String columnPropagateSourceType) |
A comma-separated list of regular expressions matching
fully-qualified names of columns that adds the columns original type
and original length as parameters to the corresponding field schemas
in the emitted change records.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.columnWhitelist(String columnWhitelist) |
Regular expressions matching columns to include in change events
(deprecated, use column.include.list instead).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.converters(String converters) |
Optional list of custom converters that would be used instead of
default ones.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseDbname(String databaseDbname) |
The name of the database the connector should be monitoring.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseHistoryFileFilename(String databaseHistoryFileFilename) |
The path to the file that will be used to record the database
history.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseHostname(String databaseHostname) |
Resolvable hostname or IP address of the Postgres database server.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseInitialStatements(String databaseInitialStatements) |
A semicolon separated list of SQL statements to be executed when a
JDBC connection to the database is established.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databasePassword(String databasePassword) |
Password of the Postgres database user to be used when connecting to
the database.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databasePort(int databasePort) |
Port of the Postgres database server.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databasePort(String databasePort) |
Port of the Postgres database server.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseServerName(String databaseServerName) |
Unique name that identifies the database server and all recorded
offsets, and that is used as a prefix for all schemas and topics.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseSslcert(String databaseSslcert) |
File containing the SSL Certificate for the client.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseSslfactory(String databaseSslfactory) |
A name of class to that creates SSL Sockets.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseSslkey(String databaseSslkey) |
File containing the SSL private key for the client.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseSslmode(String databaseSslmode) |
Whether to use an encrypted connection to Postgres.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseSslpassword(String databaseSslpassword) |
Password to access the client private key from the file specified by
'database.sslkey'.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseSslrootcert(String databaseSslrootcert) |
File containing the root certificate(s) against which the server is
validated.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseTcpkeepalive(boolean databaseTcpkeepalive) |
Enable or disable TCP keep-alive probe to avoid dropping TCP
connection.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseTcpkeepalive(String databaseTcpkeepalive) |
Enable or disable TCP keep-alive probe to avoid dropping TCP
connection.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.databaseUser(String databaseUser) |
Name of the Postgres database user to be used when connecting to the
database.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.datatypePropagateSourceType(String datatypePropagateSourceType) |
A comma-separated list of regular expressions matching the
database-specific data type names that adds the data type's original
type and original length as parameters to the corresponding field
schemas in the emitted change records.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresBuilders.debeziumPostgres(String path) |
Debezium PostgresSQL Connector (camel-debezium-postgres)
Capture changes from a PostgresSQL database.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresBuilders.debeziumPostgres(String componentName,
String path) |
Debezium PostgresSQL Connector (camel-debezium-postgres)
Capture changes from a PostgresSQL database.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.decimalHandlingMode(String decimalHandlingMode) |
Specify how DECIMAL and NUMERIC columns should be represented in
change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the
change events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to
represent values; 'double' represents values using Java's 'double',
which may not offer the precision but will be far easier to use in
consumers.
|
static DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.endpointBuilder(String componentName,
String path) |
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.eventProcessingFailureHandlingMode(String eventProcessingFailureHandlingMode) |
Specify how failures during processing of events (i.e.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.heartbeatActionQuery(String heartbeatActionQuery) |
The query executed with every heartbeat.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.heartbeatIntervalMs(int heartbeatIntervalMs) |
Length of an interval in milli-seconds in in which the connector
periodically sends heartbeat messages to a heartbeat topic.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.heartbeatIntervalMs(String heartbeatIntervalMs) |
Length of an interval in milli-seconds in in which the connector
periodically sends heartbeat messages to a heartbeat topic.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.heartbeatTopicsPrefix(String heartbeatTopicsPrefix) |
The prefix that is used to name heartbeat topics.Defaults to
__debezium-heartbeat.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.hstoreHandlingMode(String hstoreHandlingMode) |
Specify how HSTORE columns should be represented in change events,
including:'json' represents values as string-ified JSON
(default)'map' represents values as a key/value map.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.includeUnknownDatatypes(boolean includeUnknownDatatypes) |
Specify whether the fields of data type not supported by Debezium
should be processed:'false' (the default) omits the fields; 'true'
converts the field into an implementation dependent binary
representation.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.includeUnknownDatatypes(String includeUnknownDatatypes) |
Specify whether the fields of data type not supported by Debezium
should be processed:'false' (the default) omits the fields; 'true'
converts the field into an implementation dependent binary
representation.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.internalKeyConverter(String internalKeyConverter) |
The Converter class that should be used to serialize and deserialize
key data for offsets.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.internalValueConverter(String internalValueConverter) |
The Converter class that should be used to serialize and deserialize
value data for offsets.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.intervalHandlingMode(String intervalHandlingMode) |
Specify how INTERVAL columns should be represented in change events,
including:'string' represents values as an exact ISO formatted
string'numeric' (default) represents values using the inexact
conversion into microseconds.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.maxBatchSize(int maxBatchSize) |
Maximum size of each batch of source records.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.maxBatchSize(String maxBatchSize) |
Maximum size of each batch of source records.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.maxQueueSize(int maxQueueSize) |
Maximum size of the queue for change events read from the database
log but not yet recorded or forwarded.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.maxQueueSize(String maxQueueSize) |
Maximum size of the queue for change events read from the database
log but not yet recorded or forwarded.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.messageKeyColumns(String messageKeyColumns) |
A semicolon-separated list of expressions that match fully-qualified
tables and column(s) to be used as message key.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetCommitPolicy(String offsetCommitPolicy) |
The name of the Java class of the commit policy.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetCommitTimeoutMs(long offsetCommitTimeoutMs) |
Maximum number of milliseconds to wait for records to flush and
partition offset data to be committed to offset storage before
cancelling the process and restoring the offset data to be committed
in a future attempt.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetCommitTimeoutMs(String offsetCommitTimeoutMs) |
Maximum number of milliseconds to wait for records to flush and
partition offset data to be committed to offset storage before
cancelling the process and restoring the offset data to be committed
in a future attempt.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetFlushIntervalMs(long offsetFlushIntervalMs) |
Interval at which to try committing offsets.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetFlushIntervalMs(String offsetFlushIntervalMs) |
Interval at which to try committing offsets.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetStorage(String offsetStorage) |
The name of the Java class that is responsible for persistence of
connector offsets.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetStorageFileName(String offsetStorageFileName) |
Path to file where offsets are to be stored.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetStoragePartitions(int offsetStoragePartitions) |
The number of partitions used when creating the offset storage topic.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetStoragePartitions(String offsetStoragePartitions) |
The number of partitions used when creating the offset storage topic.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetStorageReplicationFactor(int offsetStorageReplicationFactor) |
Replication factor used when creating the offset storage topic.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetStorageReplicationFactor(String offsetStorageReplicationFactor) |
Replication factor used when creating the offset storage topic.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.offsetStorageTopic(String offsetStorageTopic) |
The name of the Kafka topic where offsets are to be stored.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.pluginName(String pluginName) |
The name of the Postgres logical decoding plugin installed on the
server.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.pollIntervalMs(long pollIntervalMs) |
Frequency in milliseconds to wait for new change events to appear
after receiving no events.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.pollIntervalMs(String pollIntervalMs) |
Frequency in milliseconds to wait for new change events to appear
after receiving no events.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.provideTransactionMetadata(boolean provideTransactionMetadata) |
Enables transaction metadata extraction together with event counting.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.provideTransactionMetadata(String provideTransactionMetadata) |
Enables transaction metadata extraction together with event counting.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.publicationAutocreateMode(String publicationAutocreateMode) |
Applies only when streaming changes using pgoutput.Determine how
creation of a publication should work, the default is
all_tables.DISABLED - The connector will not attempt to create a
publication at all.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.publicationName(String publicationName) |
The name of the Postgres 10 publication used for streaming changes
from a plugin.Defaults to 'dbz_publication'.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.queryFetchSize(int queryFetchSize) |
The maximum number of records that should be loaded into memory while
streaming.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.queryFetchSize(String queryFetchSize) |
The maximum number of records that should be loaded into memory while
streaming.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.retriableRestartConnectorWaitMs(long retriableRestartConnectorWaitMs) |
Time to wait before restarting connector after retriable exception
occurs.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.retriableRestartConnectorWaitMs(String retriableRestartConnectorWaitMs) |
Time to wait before restarting connector after retriable exception
occurs.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.sanitizeFieldNames(boolean sanitizeFieldNames) |
Whether field names will be sanitized to Avro naming conventions.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.sanitizeFieldNames(String sanitizeFieldNames) |
Whether field names will be sanitized to Avro naming conventions.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.schemaBlacklist(String schemaBlacklist) |
The schemas for which events must not be captured (deprecated, use
schema.exclude.list instead).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.schemaExcludeList(String schemaExcludeList) |
The schemas for which events must not be captured.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.schemaIncludeList(String schemaIncludeList) |
The schemas for which events should be captured.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.schemaRefreshMode(String schemaRefreshMode) |
Specify the conditions that trigger a refresh of the in-memory schema
for a table.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.schemaWhitelist(String schemaWhitelist) |
The schemas for which events should be captured (deprecated, use
schema.include.list instead).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.skippedOperations(String skippedOperations) |
The comma-separated list of operations to skip during streaming,
defined as: 'i' for inserts; 'u' for updates; 'd' for deletes.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotDropOnStop(boolean slotDropOnStop) |
Whether or not to drop the logical replication slot when the
connector finishes orderlyBy default the replication is kept so that
on restart progress can resume from the last recorded location.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotDropOnStop(String slotDropOnStop) |
Whether or not to drop the logical replication slot when the
connector finishes orderlyBy default the replication is kept so that
on restart progress can resume from the last recorded location.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotMaxRetries(int slotMaxRetries) |
How many times to retry connecting to a replication slot when an
attempt fails.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotMaxRetries(String slotMaxRetries) |
How many times to retry connecting to a replication slot when an
attempt fails.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotName(String slotName) |
The name of the Postgres logical decoding slot created for streaming
changes from a plugin.Defaults to 'debezium.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotRetryDelayMs(long slotRetryDelayMs) |
The number of milli-seconds to wait between retry attempts when the
connector fails to connect to a replication slot.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotRetryDelayMs(String slotRetryDelayMs) |
The number of milli-seconds to wait between retry attempts when the
connector fails to connect to a replication slot.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.slotStreamParams(String slotStreamParams) |
Any optional parameters used by logical decoding plugin.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotCustomClass(String snapshotCustomClass) |
When 'snapshot.mode' is set as custom, this setting must be set to
specify a fully qualified class name to load (via the default class
loader).This class must implement the 'Snapshotter' interface and is
called on each app boot to determine whether to do a snapshot and how
to build queries.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotDelayMs(long snapshotDelayMs) |
The number of milliseconds to delay before a snapshot will begin.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotDelayMs(String snapshotDelayMs) |
The number of milliseconds to delay before a snapshot will begin.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotFetchSize(int snapshotFetchSize) |
The maximum number of records that should be loaded into memory while
performing a snapshot.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotFetchSize(String snapshotFetchSize) |
The maximum number of records that should be loaded into memory while
performing a snapshot.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotLockTimeoutMs(long snapshotLockTimeoutMs) |
The maximum number of millis to wait for table locks at the beginning
of a snapshot.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotLockTimeoutMs(String snapshotLockTimeoutMs) |
The maximum number of millis to wait for table locks at the beginning
of a snapshot.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotMode(String snapshotMode) |
The criteria for running a snapshot upon startup of the connector.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.snapshotSelectStatementOverrides(String snapshotSelectStatementOverrides) |
This property contains a comma-separated list of fully-qualified
tables (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
thespecific connectors .
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.sourceStructVersion(String sourceStructVersion) |
A version of the format of the publicly visible source part in the
message.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.statusUpdateIntervalMs(int statusUpdateIntervalMs) |
Frequency in milliseconds for sending replication connection status
updates to the server.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.statusUpdateIntervalMs(String statusUpdateIntervalMs) |
Frequency in milliseconds for sending replication connection status
updates to the server.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tableBlacklist(String tableBlacklist) |
A comma-separated list of regular expressions that match the
fully-qualified names of tables to be excluded from monitoring
(deprecated, use table.exclude.list instead).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tableExcludeList(String tableExcludeList) |
A comma-separated list of regular expressions that match the
fully-qualified names of tables to be excluded from monitoring.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tableIgnoreBuiltin(boolean tableIgnoreBuiltin) |
Flag specifying whether built-in tables should be ignored.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tableIgnoreBuiltin(String tableIgnoreBuiltin) |
Flag specifying whether built-in tables should be ignored.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tableIncludeList(String tableIncludeList) |
The tables for which changes are to be captured.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tableWhitelist(String tableWhitelist) |
The tables for which changes are to be captured (deprecated, use
table.include.list instead).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.timePrecisionMode(String timePrecisionMode) |
Time, date, and timestamps can be represented with different kinds of
precisions, including:'adaptive' (the default) bases the precision of
time, date, and timestamp values on the database column's precision;
'adaptive_time_microseconds' like 'adaptive' mode, but TIME fields
always use microseconds precision;'connect' always represents time,
date, and timestamp values using Kafka Connect's built-in
representations for Time, Date, and Timestamp, which uses millisecond
precision regardless of the database columns' precision .
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.toastedValuePlaceholder(String toastedValuePlaceholder) |
Specify the constant that will be provided by Debezium to indicate
that the original value is a toasted value not provided by the
database.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tombstonesOnDelete(boolean tombstonesOnDelete) |
Whether delete operations should be represented by a delete event and
a subsquenttombstone event (true) or only by a delete event (false).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.tombstonesOnDelete(String tombstonesOnDelete) |
Whether delete operations should be represented by a delete event and
a subsquenttombstone event (true) or only by a delete event (false).
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.xminFetchIntervalMs(long xminFetchIntervalMs) |
Specify how often (in ms) the xmin will be fetched from the
replication slot.
|
default DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder |
DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresEndpointBuilder.xminFetchIntervalMs(String xminFetchIntervalMs) |
Specify how often (in ms) the xmin will be fetched from the
replication slot.
|