Uses of Class
io.debezium.connector.common.DebeziumHeaderProducer

Packages that use DebeziumHeaderProducer

Package	Description
io.debezium.connector.common
io.debezium.pipeline

Uses of DebeziumHeaderProducer in io.debezium.connector.common

Methods in io.debezium.connector.common that return DebeziumHeaderProducer

Modifier and Type	Method	Description
DebeziumHeaderProducer	DebeziumHeaderProducerProvider.createService(io.debezium.config.Configuration configuration, ServiceRegistry serviceRegistry)

Methods in io.debezium.connector.common that return types with arguments of type DebeziumHeaderProducer

Modifier and Type	Method	Description
Class<DebeziumHeaderProducer>	DebeziumHeaderProducerProvider.getServiceClass()

Uses of DebeziumHeaderProducer in io.debezium.pipeline

Fields in io.debezium.pipeline declared as DebeziumHeaderProducer

Modifier and Type	Field	Description
private final DebeziumHeaderProducer	EventDispatcher.debeziumHeaderProducer

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

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