Class DebeziumPostgresComponentBuilderFactory.DebeziumPostgresComponentBuilderImpl

java.lang.Object

org.apache.camel.builder.component.AbstractComponentBuilder<org.apache.camel.component.debezium.postgres.DebeziumPostgresComponent>

org.apache.camel.builder.component.dsl.DebeziumPostgresComponentBuilderFactory.DebeziumPostgresComponentBuilderImpl

All Implemented Interfaces:

ComponentBuilder<org.apache.camel.component.debezium.postgres.DebeziumPostgresComponent>, DebeziumPostgresComponentBuilderFactory.DebeziumPostgresComponentBuilder

Enclosing interface:

DebeziumPostgresComponentBuilderFactory

public static class DebeziumPostgresComponentBuilderFactory.DebeziumPostgresComponentBuilderImpl
extends AbstractComponentBuilder<org.apache.camel.component.debezium.postgres.DebeziumPostgresComponent>
implements DebeziumPostgresComponentBuilderFactory.DebeziumPostgresComponentBuilder

Constructor Summary

Constructors

Constructor	Description
DebeziumPostgresComponentBuilderImpl()

Method Summary

Modifier and Type	Method	Description
protected org.apache.camel.component.debezium.postgres.DebeziumPostgresComponent	buildConcreteComponent()
protected boolean	setPropertyOnComponent(org.apache.camel.Component component, String name, Object value)

Methods inherited from class AbstractComponentBuilder

build, build, doSetProperty, register

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ComponentBuilder

build, build, doSetProperty, register

Methods inherited from interface DebeziumPostgresComponentBuilderFactory.DebeziumPostgresComponentBuilder

additionalProperties, autowiredEnabled, binaryHandlingMode, bridgeErrorHandler, columnExcludeList, columnIncludeList, columnPropagateSourceType, configuration, connectionValidationTimeoutMs, converters, customMetricTags, customSanitizePattern, databaseDbname, databaseHostname, databaseInitialStatements, databasePassword, databasePort, databaseQueryTimeoutMs, databaseSslcert, databaseSslfactory, databaseSslkey, databaseSslmode, databaseSslpassword, databaseSslrootcert, databaseTcpkeepalive, databaseUser, datatypePropagateSourceType, decimalHandlingMode, errorsMaxRetries, eventProcessingFailureHandlingMode, executorShutdownTimeoutMs, extendedHeadersEnabled, guardrailCollectionsLimitAction, guardrailCollectionsMax, heartbeatActionQuery, heartbeatIntervalMs, heartbeatTopicsPrefix, hstoreHandlingMode, includeSchemaComments, includeUnknownDatatypes, incrementalSnapshotChunkSize, incrementalSnapshotWatermarkingStrategy, internalKeyConverter, internalValueConverter, intervalHandlingMode, lsnFlushMode, lsnFlushTimeoutAction, lsnFlushTimeoutMs, maxBatchSize, maxQueueSize, maxQueueSizeInBytes, messageKeyColumns, messagePrefixExcludeList, messagePrefixIncludeList, notificationEnabledChannels, notificationSinkTopicName, offsetCommitPolicy, offsetCommitTimeoutMs, offsetFlushIntervalMs, offsetStorage, offsetStorageFileName, offsetStoragePartitions, offsetStorageReplicationFactor, offsetStorageTopic, openlineageIntegrationConfigFilePath, openlineageIntegrationDatasetKafkaBootstrapServers, openlineageIntegrationEnabled, openlineageIntegrationJobDescription, openlineageIntegrationJobNamespace, openlineageIntegrationJobOwners, openlineageIntegrationJobTags, pluginName, pollIntervalMs, postProcessors, provideTransactionMetadata, publicationAutocreateMode, publicationName, publishViaPartitionRoot, queryFetchSize, replicaIdentityAutosetValues, retriableRestartConnectorWaitMs, schemaExcludeList, schemaHistoryInternalFileFilename, schemaIncludeList, schemaNameAdjustmentMode, schemaRefreshMode, signalDataCollection, signalEnabledChannels, signalPollIntervalMs, skippedOperations, slotDropOnStop, slotFailover, slotMaxRetries, slotName, slotRetryDelayMs, slotStreamParams, snapshotDelayMs, snapshotFetchSize, snapshotIncludeCollectionList, snapshotIsolationMode, snapshotLockingMode, snapshotLockingModeCustomName, snapshotLockTimeoutMs, snapshotMaxThreads, snapshotMaxThreadsMultiplier, snapshotMode, snapshotModeConfigurationBasedSnapshotData, snapshotModeConfigurationBasedSnapshotOnDataError, snapshotModeConfigurationBasedSnapshotOnSchemaError, snapshotModeConfigurationBasedSnapshotSchema, snapshotModeConfigurationBasedStartStream, snapshotModeCustomName, snapshotQueryMode, snapshotQueryModeCustomName, snapshotSelectStatementOverrides, snapshotTablesOrderByRowCount, sourceinfoStructMaker, statusUpdateIntervalMs, streamingDelayMs, tableExcludeList, tableIgnoreBuiltin, tableIncludeList, timePrecisionMode, tombstonesOnDelete, topicNamingStrategy, topicPrefix, transactionMetadataFactory, unavailableValuePlaceholder, xminFetchIntervalMs

Constructor Details

DebeziumPostgresComponentBuilderImpl

public DebeziumPostgresComponentBuilderImpl()

Method Details

buildConcreteComponent

protected org.apache.camel.component.debezium.postgres.DebeziumPostgresComponent buildConcreteComponent()

Specified by:

buildConcreteComponent in class AbstractComponentBuilder<org.apache.camel.component.debezium.postgres.DebeziumPostgresComponent>

setPropertyOnComponent

protected boolean setPropertyOnComponent(org.apache.camel.Component component,
 String name,
 Object value)

Specified by:

setPropertyOnComponent in class AbstractComponentBuilder<org.apache.camel.component.debezium.postgres.DebeziumPostgresComponent>