Package io.debezium.heartbeat
package io.debezium.heartbeat
-
ClassDescriptionComposite Heartbeat solutions (Queue, Database...)Implementation of the heartbeat feature that allows for a DB query to be executed with every heartbeat.factory interface for creating the appropriate
Heartbeatimplementation based on the connector and contextA class that is able to emit heartbeat messages.Returns the offset to be used when emitting a heartbeat event.A class that is able to generate periodic heartbeat messages based on a pre-configured interval.Defines a contract for providing a connection to theDatabaseHeartbeatImpl.HeartbeatFactory<T extends io.debezium.spi.schema.DataCollectionId>Default factory for creating the appropriateHeartbeatimplementation based on the connector type and its configured properties in the Debezium context.Default implementation of Heartbeat