default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.AdvancedDebeziumMongodbEndpointBuilder.basic() |
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.collectionExcludeList(String collectionExcludeList) |
A comma-separated list of regular expressions that match the
collection names for which changes are to be excluded.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.collectionIncludeList(String collectionIncludeList) |
A comma-separated list of regular expressions that match the
collection names for which changes are to be captured.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.connectBackoffInitialDelayMs(long connectBackoffInitialDelayMs) |
The initial delay when trying to reconnect to a primary after a
connection cannot be made or when no primary is available.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.connectBackoffInitialDelayMs(String connectBackoffInitialDelayMs) |
The initial delay when trying to reconnect to a primary after a
connection cannot be made or when no primary is available.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.connectBackoffMaxDelayMs(long connectBackoffMaxDelayMs) |
The maximum delay when trying to reconnect to a primary after a
connection cannot be made or when no primary is available.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.connectBackoffMaxDelayMs(String connectBackoffMaxDelayMs) |
The maximum delay when trying to reconnect to a primary after a
connection cannot be made or when no primary is available.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.connectMaxAttempts(int connectMaxAttempts) |
Maximum number of failed connection attempts to a replica set primary
before an exception occurs and task is aborted.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.connectMaxAttempts(String connectMaxAttempts) |
Maximum number of failed connection attempts to a replica set primary
before an exception occurs and task is aborted.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.converters(String converters) |
Optional list of custom converters that would be used instead of
default ones.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.databaseExcludeList(String databaseExcludeList) |
A comma-separated list of regular expressions that match the database
names for which changes are to be excluded.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.databaseHistoryFileFilename(String databaseHistoryFileFilename) |
The path to the file that will be used to record the database
history.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.databaseIncludeList(String databaseIncludeList) |
A comma-separated list of regular expressions that match the database
names for which changes are to be captured.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbBuilders.debeziumMongodb(String path) |
Debezium MongoDB Connector (camel-debezium-mongodb)
Capture changes from a MongoDB database.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbBuilders.debeziumMongodb(String componentName,
String path) |
Debezium MongoDB Connector (camel-debezium-mongodb)
Capture changes from a MongoDB database.
|
static DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.endpointBuilder(String componentName,
String path) |
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.eventProcessingFailureHandlingMode(String eventProcessingFailureHandlingMode) |
Specify how failures during processing of events (i.e.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.fieldExcludeList(String fieldExcludeList) |
A comma-separated list of the fully-qualified names of fields that
should be excluded from change event message values.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.fieldRenames(String fieldRenames) |
Description is not available here, please check Debezium website for
corresponding key 'field.renames' description.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.heartbeatIntervalMs(int heartbeatIntervalMs) |
Length of an interval in milli-seconds in in which the connector
periodically sends heartbeat messages to a heartbeat topic.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.heartbeatIntervalMs(String heartbeatIntervalMs) |
Length of an interval in milli-seconds in in which the connector
periodically sends heartbeat messages to a heartbeat topic.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.heartbeatTopicsPrefix(String heartbeatTopicsPrefix) |
The prefix that is used to name heartbeat topics.Defaults to
__debezium-heartbeat.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.initialSyncMaxThreads(int initialSyncMaxThreads) |
Maximum number of threads used to perform an initial sync of the
collections in a replica set.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.initialSyncMaxThreads(String initialSyncMaxThreads) |
Maximum number of threads used to perform an initial sync of the
collections in a replica set.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.internalKeyConverter(String internalKeyConverter) |
The Converter class that should be used to serialize and deserialize
key data for offsets.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.internalValueConverter(String internalValueConverter) |
The Converter class that should be used to serialize and deserialize
value data for offsets.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.maxBatchSize(int maxBatchSize) |
Maximum size of each batch of source records.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.maxBatchSize(String maxBatchSize) |
Maximum size of each batch of source records.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.maxQueueSize(int maxQueueSize) |
Maximum size of the queue for change events read from the database
log but not yet recorded or forwarded.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.maxQueueSize(String maxQueueSize) |
Maximum size of the queue for change events read from the database
log but not yet recorded or forwarded.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbAuthsource(String mongodbAuthsource) |
Database containing user credentials.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbConnectTimeoutMs(int mongodbConnectTimeoutMs) |
The connection timeout in milliseconds.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbConnectTimeoutMs(String mongodbConnectTimeoutMs) |
The connection timeout in milliseconds.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbHosts(String mongodbHosts) |
The hostname and port pairs (in the form 'host' or 'host:port') of
the MongoDB server(s) in the replica set.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbMembersAutoDiscover(boolean mongodbMembersAutoDiscover) |
Specifies whether the addresses in 'hosts' are seeds that should be
used to discover all members of the cluster or replica set ('true'),
or whether the address(es) in 'hosts' should be used as is ('false').
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbMembersAutoDiscover(String mongodbMembersAutoDiscover) |
Specifies whether the addresses in 'hosts' are seeds that should be
used to discover all members of the cluster or replica set ('true'),
or whether the address(es) in 'hosts' should be used as is ('false').
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbName(String mongodbName) |
Unique name that identifies the MongoDB replica set or cluster and
all recorded offsets, andthat is used as a prefix for all schemas and
topics.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbPassword(String mongodbPassword) |
Password to be used when connecting to MongoDB, if necessary.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbPollIntervalMs(long mongodbPollIntervalMs) |
Frequency in milliseconds to look for new, removed, or changed
replica sets.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbPollIntervalMs(String mongodbPollIntervalMs) |
Frequency in milliseconds to look for new, removed, or changed
replica sets.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbServerSelectionTimeoutMs(int mongodbServerSelectionTimeoutMs) |
The server selection timeout in milliseconds.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbServerSelectionTimeoutMs(String mongodbServerSelectionTimeoutMs) |
The server selection timeout in milliseconds.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbSocketTimeoutMs(int mongodbSocketTimeoutMs) |
The socket timeout in milliseconds.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbSocketTimeoutMs(String mongodbSocketTimeoutMs) |
The socket timeout in milliseconds.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbSslEnabled(boolean mongodbSslEnabled) |
Should connector use SSL to connect to MongoDB instances.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbSslEnabled(String mongodbSslEnabled) |
Should connector use SSL to connect to MongoDB instances.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbSslInvalidHostnameAllowed(boolean mongodbSslInvalidHostnameAllowed) |
Whether invalid host names are allowed when using SSL.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbSslInvalidHostnameAllowed(String mongodbSslInvalidHostnameAllowed) |
Whether invalid host names are allowed when using SSL.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.mongodbUser(String mongodbUser) |
Database user for connecting to MongoDB, if necessary.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetCommitPolicy(String offsetCommitPolicy) |
The name of the Java class of the commit policy.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetFlushIntervalMs(long offsetFlushIntervalMs) |
Interval at which to try committing offsets.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetFlushIntervalMs(String offsetFlushIntervalMs) |
Interval at which to try committing offsets.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetStorage(String offsetStorage) |
The name of the Java class that is responsible for persistence of
connector offsets.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetStorageFileName(String offsetStorageFileName) |
Path to file where offsets are to be stored.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetStoragePartitions(int offsetStoragePartitions) |
The number of partitions used when creating the offset storage topic.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetStoragePartitions(String offsetStoragePartitions) |
The number of partitions used when creating the offset storage topic.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetStorageReplicationFactor(int offsetStorageReplicationFactor) |
Replication factor used when creating the offset storage topic.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetStorageReplicationFactor(String offsetStorageReplicationFactor) |
Replication factor used when creating the offset storage topic.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.offsetStorageTopic(String offsetStorageTopic) |
The name of the Kafka topic where offsets are to be stored.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.pollIntervalMs(long pollIntervalMs) |
Frequency in milliseconds to wait for new change events to appear
after receiving no events.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.pollIntervalMs(String pollIntervalMs) |
Frequency in milliseconds to wait for new change events to appear
after receiving no events.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.provideTransactionMetadata(boolean provideTransactionMetadata) |
Enables transaction metadata extraction together with event counting.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.provideTransactionMetadata(String provideTransactionMetadata) |
Enables transaction metadata extraction together with event counting.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.queryFetchSize(int queryFetchSize) |
The maximum number of records that should be loaded into memory while
streaming.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.queryFetchSize(String queryFetchSize) |
The maximum number of records that should be loaded into memory while
streaming.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.retriableRestartConnectorWaitMs(long retriableRestartConnectorWaitMs) |
Time to wait before restarting connector after retriable exception
occurs.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.retriableRestartConnectorWaitMs(String retriableRestartConnectorWaitMs) |
Time to wait before restarting connector after retriable exception
occurs.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.sanitizeFieldNames(boolean sanitizeFieldNames) |
Whether field names will be sanitized to Avro naming conventions.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.sanitizeFieldNames(String sanitizeFieldNames) |
Whether field names will be sanitized to Avro naming conventions.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.snapshotDelayMs(long snapshotDelayMs) |
The number of milliseconds to delay before a snapshot will begin.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.snapshotDelayMs(String snapshotDelayMs) |
The number of milliseconds to delay before a snapshot will begin.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.snapshotFetchSize(int snapshotFetchSize) |
The maximum number of records that should be loaded into memory while
performing a snapshot.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.snapshotFetchSize(String snapshotFetchSize) |
The maximum number of records that should be loaded into memory while
performing a snapshot.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.snapshotMode(String snapshotMode) |
The criteria for running a snapshot upon startup of the connector.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.sourceStructVersion(String sourceStructVersion) |
A version of the format of the publicly visible source part in the
message.
|
default DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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 DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder |
DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbEndpointBuilder.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).
|