Uses of Class
io.debezium.config.CommonConnectorConfig
Packages that use CommonConnectorConfig
Package
Description
-
Uses of CommonConnectorConfig in io.debezium.config
Methods in io.debezium.config with parameters of type CommonConnectorConfigModifier and TypeMethodDescription<T extends AbstractSourceInfo>
SourceInfoStructMaker<T> CommonConnectorConfig.getSourceInfoStructMaker(io.debezium.config.Field sourceInfoStructMakerField, String connector, String version, CommonConnectorConfig connectorConfig) -
Uses of CommonConnectorConfig in io.debezium.connector
Fields in io.debezium.connector declared as CommonConnectorConfigMethods in io.debezium.connector with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionvoidAbstractSourceInfoStructMaker.init(String connector, String version, CommonConnectorConfig connectorConfig) voidLegacyV1AbstractSourceInfoStructMaker.init(String connector, String version, CommonConnectorConfig connectorConfig) voidSourceInfoStructMaker.init(String connector, String version, CommonConnectorConfig connectorConfig) Constructors in io.debezium.connector with parameters of type CommonConnectorConfig -
Uses of CommonConnectorConfig in io.debezium.connector.common
Classes in io.debezium.connector.common with type parameters of type CommonConnectorConfigModifier and TypeClassDescriptionclassCdcSourceTaskContext<T extends CommonConnectorConfig>Contains contextual information and objects scoped to the lifecycle of Debezium'sSourceTaskimplementations.Fields in io.debezium.connector.common declared as CommonConnectorConfigFields in io.debezium.connector.common with type parameters of type CommonConnectorConfigModifier and TypeFieldDescriptionprivate CdcSourceTaskContext<? extends CommonConnectorConfig> BaseSourceTask.cdcSourceTaskContextMethods in io.debezium.connector.common that return types with arguments of type CommonConnectorConfigModifier and TypeMethodDescriptionabstract CdcSourceTaskContext<? extends CommonConnectorConfig> BaseSourceTask.preStart(io.debezium.config.Configuration config) Methods in io.debezium.connector.common with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionbooleanBaseSourceTask.isLogPositionAvailable(LogPositionValidator logPositionValidator, Partition partition, OffsetContext offsetContext, CommonConnectorConfig config) voidCdcSourceTaskContext.temporaryLoggingContext(CommonConnectorConfig connectorConfig, String contextName, Runnable operation) Run the supplied function in the temporary connector MDC context, and when complete always return the MDC context to its state before this method was called.protected voidBaseSourceTask.validateSchemaHistory(CommonConnectorConfig config, LogPositionValidator logPositionValidator, Offsets<P, O> previousOffsets, DatabaseSchema schema, io.debezium.spi.snapshot.Snapshotter snapshotter) Constructors in io.debezium.connector.common with parameters of type CommonConnectorConfig -
Uses of CommonConnectorConfig in io.debezium.function
Methods in io.debezium.function with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionbooleanLogPositionValidator.validate(Partition partition, OffsetContext offsetContext, CommonConnectorConfig config) Validate the stored offset with the position available in the db log. -
Uses of CommonConnectorConfig in io.debezium.heartbeat
Fields in io.debezium.heartbeat declared as CommonConnectorConfigModifier and TypeFieldDescriptionprivate final CommonConnectorConfigHeartbeatFactory.connectorConfigMethods in io.debezium.heartbeat with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionDatabaseHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) DebeziumHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) default Heartbeat.ScheduledHeartbeatDebeziumHeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) HeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) Create a heartbeat instance that can be scheduled with some delay based onCommonConnectorConfigConstructors in io.debezium.heartbeat with parameters of type CommonConnectorConfigModifierConstructorDescriptionHeartbeatFactory(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, SchemaNameAdjuster schemaNameAdjuster) Deprecated.HeartbeatFactory(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, SchemaNameAdjuster schemaNameAdjuster, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler) Deprecated. -
Uses of CommonConnectorConfig in io.debezium.jdbc
Methods in io.debezium.jdbc with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionJdbcConnection.readTablePreparedStatement(CommonConnectorConfig connectorConfig, String sql, OptionalLong tableSize) Allow per-connector prepared query creation to override for best database performance depending on the table size.JdbcConnection.readTableStatement(CommonConnectorConfig connectorConfig, OptionalLong tableSize) Allow per-connector query creation to override for best database performance depending on the table size. -
Uses of CommonConnectorConfig in io.debezium.metrics
Constructors in io.debezium.metrics with parameters of type CommonConnectorConfigModifierConstructorDescriptionprotectedMetrics(CommonConnectorConfig connectorConfig, String contextName, boolean multiPartitionMode) -
Uses of CommonConnectorConfig in io.debezium.metrics.stats
Methods in io.debezium.metrics.stats with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionstatic <T extends SingleValueEvent<Long>>
MeasurementStatistics<T, Long> MeasurementStatisticsFactory.createStatistics(CommonConnectorConfig config) -
Uses of CommonConnectorConfig in io.debezium.pipeline
Fields in io.debezium.pipeline declared as CommonConnectorConfigModifier and TypeFieldDescriptionprivate final CommonConnectorConfigAbstractChangeRecordEmitter.connectorConfigprotected final CommonConnectorConfigChangeEventSourceCoordinator.connectorConfigprivate final CommonConnectorConfigErrorHandler.connectorConfigprivate final CommonConnectorConfigEventDispatcher.connectorConfigprivate final CommonConnectorConfigGuardrailValidator.connectorConfigMethods in io.debezium.pipeline with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionprivate static StringJmxUtils.getManagementJmxObjectName(String type, String context, CommonConnectorConfig connectorConfig) private static Predicate<SignalActionProvider> ChangeEventSourceCoordinator.getUniversalProviderOrConnectorSpecific(CommonConnectorConfig connectorConfig) static voidJmxUtils.registerMXBean(Object mxBean, CommonConnectorConfig connectorConfig, String type, String context) protected voidChangeEventSourceCoordinator.registerSignalActionsAndStartProcessor(SignalProcessor<P, O> signalProcessor, EventDispatcher<P, ? extends io.debezium.spi.schema.DataCollectionId> dispatcher, ChangeEventSourceCoordinator<P, ?> changeEventSourceCoordinator, CommonConnectorConfig connectorConfig) static voidJmxUtils.unregisterMXBean(CommonConnectorConfig connectorConfig, String type, String context) Constructors in io.debezium.pipeline with parameters of type CommonConnectorConfigModifierConstructorDescriptionAbstractChangeRecordEmitter(P partition, OffsetContext offsetContext, io.debezium.util.Clock clock, CommonConnectorConfig connectorConfig) ChangeEventSourceCoordinator(Offsets<P, O> previousOffsets, ErrorHandler errorHandler, Class<? extends org.apache.kafka.connect.source.SourceConnector> connectorType, CommonConnectorConfig connectorConfig, ChangeEventSourceFactory<P, O> changeEventSourceFactory, ChangeEventSourceMetricsFactory<P> changeEventSourceMetricsFactory, EventDispatcher<P, ?> eventDispatcher, DatabaseSchema<?> schema, SignalProcessor<P, O> signalProcessor, NotificationService<P, O> notificationService, SnapshotterService snapshotterService) ErrorHandler(Class<? extends org.apache.kafka.connect.source.SourceConnector> connectorType, CommonConnectorConfig connectorConfig, ChangeEventQueue<?> queue, ErrorHandler replacedErrorHandler) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventDispatcher.InconsistentSchemaHandler<P, T> inconsistentSchemaHandler, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, TransactionMonitor transactionMonitor, SignalProcessor<P, ?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventDispatcher.InconsistentSchemaHandler<P, T> inconsistentSchemaHandler, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P, ?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P, ?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, SchemaNameAdjuster schemaNameAdjuster, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P, ?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer) GuardrailValidator(CommonConnectorConfig connectorConfig) Constructor for collection-based connectors (e.g., MongoDB).GuardrailValidator(CommonConnectorConfig connectorConfig, DatabaseSchema<?> schema) Constructor for relational database connectors. -
Uses of CommonConnectorConfig in io.debezium.pipeline.meters
Constructors in io.debezium.pipeline.meters with parameters of type CommonConnectorConfigModifierConstructorDescriptionStreamingMeter(CommonConnectorConfig config, CapturedTablesSupplier capturedTablesSupplier, EventMetadataProvider metadataProvider) -
Uses of CommonConnectorConfig in io.debezium.pipeline.notification
Fields in io.debezium.pipeline.notification declared as CommonConnectorConfigModifier and TypeFieldDescriptionprivate final CommonConnectorConfigIncrementalSnapshotNotificationService.connectorConfigprivate final CommonConnectorConfigInitialSnapshotNotificationService.connectorConfigConstructors in io.debezium.pipeline.notification with parameters of type CommonConnectorConfigModifierConstructorDescriptionIncrementalSnapshotNotificationService(NotificationService<P, O> notificationService, CommonConnectorConfig config, Clock clock) InitialSnapshotNotificationService(NotificationService<P, O> notificationService, CommonConnectorConfig connectorConfig, Clock clock) NotificationService(List<NotificationChannel> notificationChannels, CommonConnectorConfig config, SchemaFactory schemaFactory, BlockingConsumer<org.apache.kafka.connect.source.SourceRecord> consumer) -
Uses of CommonConnectorConfig in io.debezium.pipeline.notification.channels
Methods in io.debezium.pipeline.notification.channels with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionvoidLogNotificationChannel.init(CommonConnectorConfig config) voidNotificationChannel.init(CommonConnectorConfig config) voidSinkNotificationChannel.init(CommonConnectorConfig config) -
Uses of CommonConnectorConfig in io.debezium.pipeline.notification.channels.jmx
Fields in io.debezium.pipeline.notification.channels.jmx declared as CommonConnectorConfigModifier and TypeFieldDescriptionprivate CommonConnectorConfigJmxNotificationChannel.connectorConfigMethods in io.debezium.pipeline.notification.channels.jmx with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionvoidJmxNotificationChannel.init(CommonConnectorConfig connectorConfig) -
Uses of CommonConnectorConfig in io.debezium.pipeline.signal
Fields in io.debezium.pipeline.signal declared as CommonConnectorConfigModifier and TypeFieldDescriptionprivate final CommonConnectorConfigSignalProcessor.connectorConfigMethods in io.debezium.pipeline.signal with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionstatic Optional<SignalRecord> SignalRecord.buildSignalRecordFromChangeEventSource(org.apache.kafka.connect.data.Struct value, CommonConnectorConfig config) Constructors in io.debezium.pipeline.signal with parameters of type CommonConnectorConfigModifierConstructorDescriptionSignalProcessor(Class<? extends org.apache.kafka.connect.source.SourceConnector> connector, CommonConnectorConfig config, Map<String, SignalAction<P>> signalActions, List<SignalChannelReader> signalChannelReaders, DocumentReader documentReader, Offsets<P, O> previousOffsets) -
Uses of CommonConnectorConfig in io.debezium.pipeline.signal.actions
Methods in io.debezium.pipeline.signal.actions with parameters of type CommonConnectorConfigModifier and TypeMethodDescription<P extends Partition>
Map<String, SignalAction<P>> SignalActionProvider.createActions(EventDispatcher<P, ? extends io.debezium.spi.schema.DataCollectionId> dispatcher, ChangeEventSourceCoordinator<P, ?> changeEventSourceCoordinator, CommonConnectorConfig connectorConfig) Create a map of signal action where the key is the name of the action.<P extends Partition>
Map<String, SignalAction<P>> StandardActionProvider.createActions(EventDispatcher<P, ? extends io.debezium.spi.schema.DataCollectionId> dispatcher, ChangeEventSourceCoordinator<P, ?> changeEventSourceCoordinator, CommonConnectorConfig connectorConfig) Constructors in io.debezium.pipeline.signal.actions with parameters of type CommonConnectorConfigModifierConstructorDescriptionSchemaChanges(EventDispatcher<P, ? extends io.debezium.spi.schema.DataCollectionId> dispatcher, CommonConnectorConfig connectorConfig, TableChanges.TableChangesSerializer<Array> serializer) -
Uses of CommonConnectorConfig in io.debezium.pipeline.signal.channels
Fields in io.debezium.pipeline.signal.channels declared as CommonConnectorConfigMethods in io.debezium.pipeline.signal.channels with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionvoidFileSignalChannel.init(CommonConnectorConfig connectorConfig) voidKafkaSignalChannel.init(CommonConnectorConfig connectorConfig) voidSignalChannelReader.init(CommonConnectorConfig connectorConfig) voidSourceSignalChannel.init(CommonConnectorConfig connectorConfig) -
Uses of CommonConnectorConfig in io.debezium.pipeline.signal.channels.jmx
Fields in io.debezium.pipeline.signal.channels.jmx declared as CommonConnectorConfigMethods in io.debezium.pipeline.signal.channels.jmx with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionvoidJmxSignalChannel.init(CommonConnectorConfig connectorConfig) -
Uses of CommonConnectorConfig in io.debezium.pipeline.signal.channels.process
Methods in io.debezium.pipeline.signal.channels.process with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionvoidInProcessSignalChannel.init(CommonConnectorConfig connectorConfig) -
Uses of CommonConnectorConfig in io.debezium.pipeline.source
Fields in io.debezium.pipeline.source declared as CommonConnectorConfigModifier and TypeFieldDescriptionprivate final CommonConnectorConfigAbstractSnapshotChangeEventSource.connectorConfigConstructors in io.debezium.pipeline.source with parameters of type CommonConnectorConfigModifierConstructorDescriptionAbstractSnapshotChangeEventSource(CommonConnectorConfig connectorConfig, SnapshotProgressListener<P> snapshotProgressListener, NotificationService<P, O> notificationService) -
Uses of CommonConnectorConfig in io.debezium.pipeline.source.snapshot.incremental
Methods in io.debezium.pipeline.source.snapshot.incremental with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionprivate WatermarkWindowCloserSignalBasedIncrementalSnapshotChangeEventSource.getWatermarkWindowCloser(CommonConnectorConfig connectorConfig, JdbcConnection jdbcConnection, String signalTable) -
Uses of CommonConnectorConfig in io.debezium.pipeline.txmetadata
Fields in io.debezium.pipeline.txmetadata declared as CommonConnectorConfigModifier and TypeFieldDescriptionprivate final CommonConnectorConfigTransactionMonitor.connectorConfigConstructors in io.debezium.pipeline.txmetadata with parameters of type CommonConnectorConfigModifierConstructorDescriptionTransactionMonitor(CommonConnectorConfig connectorConfig, EventMetadataProvider eventMetadataProvider, SchemaNameAdjuster schemaNameAdjuster, BlockingConsumer<org.apache.kafka.connect.source.SourceRecord> sender, String topicName) -
Uses of CommonConnectorConfig in io.debezium.relational
Subclasses of CommonConnectorConfig in io.debezium.relationalModifier and TypeClassDescriptionclassConfiguration options shared across the relational CDC connectors which use a persistent database schema history.classConfiguration options shared across the relational CDC connectors.Fields in io.debezium.relational with type parameters of type CommonConnectorConfigModifier and TypeFieldDescriptionprivate final CdcSourceTaskContext<? extends CommonConnectorConfig> RelationalDatabaseSchema.taskContextConstructor parameters in io.debezium.relational with type arguments of type CommonConnectorConfigModifierConstructorDescriptionprotectedHistorizedRelationalDatabaseSchema(HistorizedRelationalDatabaseConnectorConfig config, io.debezium.spi.topic.TopicNamingStrategy<TableId> topicNamingStrategy, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, TableSchemaBuilder schemaBuilder, boolean tableIdCaseInsensitive, Key.KeyMapper customKeysMapper, CdcSourceTaskContext<? extends CommonConnectorConfig> taskContext) protectedRelationalDatabaseSchema(RelationalDatabaseConnectorConfig config, io.debezium.spi.topic.TopicNamingStrategy<TableId> topicNamingStrategy, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, TableSchemaBuilder schemaBuilder, boolean tableIdCaseInsensitive, Key.KeyMapper customKeysMapper, CdcSourceTaskContext<? extends CommonConnectorConfig> taskContext) -
Uses of CommonConnectorConfig in io.debezium.relational.history
Constructors in io.debezium.relational.history with parameters of type CommonConnectorConfigModifierConstructorDescriptionSchemaHistoryMetrics(CommonConnectorConfig connectorConfig, boolean multiPartitionMode) -
Uses of CommonConnectorConfig in io.debezium.schema
Methods in io.debezium.schema with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionstatic DefaultTopicNamingStrategyDefaultTopicNamingStrategy.create(CommonConnectorConfig config) DefaultUnicodeTopicNamingStrategy.create(CommonConnectorConfig config) static SchemaTopicNamingStrategySchemaTopicNamingStrategy.create(CommonConnectorConfig config) static SchemaTopicNamingStrategySchemaTopicNamingStrategy.create(CommonConnectorConfig config, boolean multiPartitionMode) SchemaUnicodeTopicNamingStrategy.create(CommonConnectorConfig config) static <I extends io.debezium.spi.schema.DataCollectionId>
TopicSelector<I> TopicSelector.defaultSelector(CommonConnectorConfig connectorConfig, TopicSelector.DataCollectionTopicNamer<I> dataCollectionTopicNamer) Deprecated.org.apache.kafka.connect.data.SchemaSchemaFactory.schemaHistoryConnectorKeySchema(SchemaNameAdjuster adjuster, CommonConnectorConfig config) org.apache.kafka.connect.data.SchemaSchemaFactory.schemaHistoryConnectorValueSchema(SchemaNameAdjuster adjuster, CommonConnectorConfig config, ConnectTableChangeSerializer serializer) -
Uses of CommonConnectorConfig in io.debezium.snapshot
Methods in io.debezium.snapshot with parameters of type CommonConnectorConfigModifier and TypeMethodDescriptionSnapshotLockProvider.snapshotLockingMode(CommonConnectorConfig configuration) SnapshotterServiceProvider.snapshotMode(CommonConnectorConfig configuration)