Package io.debezium.heartbeat

Class HeartbeatFactory<T extends io.debezium.spi.schema.DataCollectionId>

java.lang.Object

io.debezium.heartbeat.HeartbeatFactory<T>

All Implemented Interfaces:

DebeziumHeartbeatFactory

public class HeartbeatFactory<T extends io.debezium.spi.schema.DataCollectionId>
extends Object
implements DebeziumHeartbeatFactory

Default factory for creating the appropriate Heartbeat implementation based on the connector type and its configured properties in the Debezium context.

Author:

Chris Cranford

Field Summary

Fields

Modifier and Type	Field	Description
private final HeartbeatConnectionProvider	connectionProvider
private final CommonConnectorConfig	connectorConfig
private final HeartbeatErrorHandler	errorHandler
private final ServiceLoader<DebeziumHeartbeatFactory>	externalHeartbeatFactory
private final List<DebeziumHeartbeatFactory>	heartbeatFactories
private final SchemaNameAdjuster	schemaNameAdjuster
private final io.debezium.spi.topic.TopicNamingStrategy<T>	topicNamingStrategy

Constructor Summary

Constructors

Constructor	Description
HeartbeatFactory()
HeartbeatFactory(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.

Method Summary

Modifier and Type	Method	Description
Heartbeat	createHeartbeat()	Deprecated. replaced by the DebeziumHeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig, HeartbeatConnectionProvider, HeartbeatErrorHandler, ChangeEventQueue)
Heartbeat.ScheduledHeartbeat	getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)	Create a heartbeat instance that can be scheduled with some delay based on CommonConnectorConfig

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.heartbeat.DebeziumHeartbeatFactory

getHeartbeat

Field Details

connectorConfig

private final CommonConnectorConfig connectorConfig

topicNamingStrategy

private final io.debezium.spi.topic.TopicNamingStrategy<T extends io.debezium.spi.schema.DataCollectionId> topicNamingStrategy

schemaNameAdjuster

private final SchemaNameAdjuster schemaNameAdjuster

connectionProvider

private final HeartbeatConnectionProvider connectionProvider

errorHandler

private final HeartbeatErrorHandler errorHandler

externalHeartbeatFactory

private final ServiceLoader<DebeziumHeartbeatFactory> externalHeartbeatFactory

heartbeatFactories

private final List<DebeziumHeartbeatFactory> heartbeatFactories

Constructor Details

HeartbeatFactory

@Deprecated
public HeartbeatFactory(CommonConnectorConfig connectorConfig,
 io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy,
 SchemaNameAdjuster schemaNameAdjuster)

Deprecated.

replaced by HeartbeatFactory()

HeartbeatFactory

@Deprecated
public HeartbeatFactory(CommonConnectorConfig connectorConfig,
 io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy,
 SchemaNameAdjuster schemaNameAdjuster,
 HeartbeatConnectionProvider connectionProvider,
 HeartbeatErrorHandler errorHandler)

Deprecated.

replaced by HeartbeatFactory()

HeartbeatFactory

public HeartbeatFactory()

Method Details

createHeartbeat

@Deprecated
public Heartbeat createHeartbeat()

Deprecated.

replaced by the DebeziumHeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig, HeartbeatConnectionProvider, HeartbeatErrorHandler, ChangeEventQueue)

getScheduledHeartbeat

public Heartbeat.ScheduledHeartbeat getScheduledHeartbeat(CommonConnectorConfig connectorConfig,
 HeartbeatConnectionProvider connectionProvider,
 HeartbeatErrorHandler errorHandler,
 ChangeEventQueue<DataChangeEvent> queue)

Create a heartbeat instance that can be scheduled with some delay based on CommonConnectorConfig

Specified by:

getScheduledHeartbeat in interface DebeziumHeartbeatFactory