Uses of Class
io.debezium.connector.base.ChangeEventQueue

Packages that use ChangeEventQueue

Package	Description
io.debezium.connector.base
io.debezium.heartbeat
io.debezium.pipeline

Uses of ChangeEventQueue in io.debezium.connector.base

Methods in io.debezium.connector.base that return ChangeEventQueue

Modifier and Type	Method	Description
ChangeEventQueue<T>	ChangeEventQueue.Builder.build()

Uses of ChangeEventQueue in io.debezium.heartbeat

Fields in io.debezium.heartbeat declared as ChangeEventQueue

Modifier and Type	Field	Description
private final ChangeEventQueue<DataChangeEvent>	HeartbeatImpl.queue

Methods in io.debezium.heartbeat with parameters of type ChangeEventQueue

Modifier and Type	Method	Description
Optional<Heartbeat>	DatabaseHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)
default Optional<Heartbeat>	DebeziumHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)
default Heartbeat.ScheduledHeartbeat	DebeziumHeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)
Heartbeat.ScheduledHeartbeat	HeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)	Create a heartbeat instance that can be scheduled with some delay based on CommonConnectorConfig

Constructors in io.debezium.heartbeat with parameters of type ChangeEventQueue

Modifier	Constructor	Description
	HeartbeatImpl(Duration heartbeatInterval, String topicName, String key, SchemaNameAdjuster schemaNameAdjuster, ChangeEventQueue<DataChangeEvent> queue)

Uses of ChangeEventQueue in io.debezium.pipeline

Fields in io.debezium.pipeline declared as ChangeEventQueue

Modifier and Type	Field	Description
private final ChangeEventQueue<?>	ErrorHandler.queue
private final ChangeEventQueue<DataChangeEvent>	EventDispatcher.queue

Constructors in io.debezium.pipeline with parameters of type ChangeEventQueue

Modifier	Constructor	Description
	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)