Package io.debezium.heartbeat

Class DatabaseHeartbeatImpl

java.lang.Object

io.debezium.heartbeat.DatabaseHeartbeatImpl

All Implemented Interfaces:

Heartbeat, AutoCloseable

public class DatabaseHeartbeatImpl
extends Object
implements Heartbeat

Implementation of the heartbeat feature that allows for a DB query to be executed with every heartbeat.

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.heartbeat.Heartbeat

Heartbeat.OffsetProducer, Heartbeat.ScheduledHeartbeat

Field Summary

Fields

Modifier and Type	Field	Description
private final HeartbeatErrorHandler	errorHandler
static final io.debezium.config.Field	HEARTBEAT_ACTION_QUERY
static final String	HEARTBEAT_ACTION_QUERY_PROPERTY_NAME
private final String	heartBeatActionQuery
private final JdbcConnection	jdbcConnection
private static final org.slf4j.Logger	LOGGER

Fields inherited from interface io.debezium.heartbeat.Heartbeat

DEFAULT_NOOP_HEARTBEAT, HEARTBEAT_INTERVAL, HEARTBEAT_INTERVAL_PROPERTY_NAME, HEARTBEAT_TOPICS_PREFIX

Constructor Summary

Constructors

Constructor	Description
DatabaseHeartbeatImpl(JdbcConnection jdbcConnection, String heartBeatActionQuery, HeartbeatErrorHandler errorHandler)

Method Summary

Modifier and Type	Method	Description
void	close()
void	emit(Map<String,?> partition, OffsetContext offset)	Generates a heartbeat record unconditionally
void	forcedBeat(Map<String,?> partition, Map<String,?> offset, BlockingConsumer<org.apache.kafka.connect.source.SourceRecord> consumer)	Generates a heartbeat record unconditionally Replaced by Heartbeat.emit(Map, OffsetContext)
boolean	isEnabled()	Whether heartbeats are enabled or not.

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.Heartbeat

heartbeat, heartbeat

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

HEARTBEAT_ACTION_QUERY_PROPERTY_NAME

public static final String HEARTBEAT_ACTION_QUERY_PROPERTY_NAME

See Also:

• Constant Field Values

HEARTBEAT_ACTION_QUERY

public static final io.debezium.config.Field HEARTBEAT_ACTION_QUERY

heartBeatActionQuery

private final String heartBeatActionQuery

jdbcConnection

private final JdbcConnection jdbcConnection

errorHandler

private final HeartbeatErrorHandler errorHandler

Constructor Details

DatabaseHeartbeatImpl

public DatabaseHeartbeatImpl(JdbcConnection jdbcConnection,
 String heartBeatActionQuery,
 HeartbeatErrorHandler errorHandler)

Method Details

isEnabled

public boolean isEnabled()

Description copied from interface: Heartbeat

Whether heartbeats are enabled or not.

Specified by:

isEnabled in interface Heartbeat

forcedBeat

public void forcedBeat(Map<String,?> partition,
 Map<String,?> offset,
 BlockingConsumer<org.apache.kafka.connect.source.SourceRecord> consumer)

Description copied from interface: Heartbeat

Generates a heartbeat record unconditionally Replaced by Heartbeat.emit(Map, OffsetContext)

Specified by:

forcedBeat in interface Heartbeat

Parameters:

partition - partition for the heartbeat record

offset - offset for the heartbeat record

consumer - - a code to place record among others to be sent into Connect

emit

public void emit(Map<String,?> partition,
 OffsetContext offset)
          throws InterruptedException

Description copied from interface: Heartbeat

Generates a heartbeat record unconditionally

Specified by:

emit in interface Heartbeat

Parameters:

partition - partition for the heartbeat record

offset - offset for the heartbeat record

Throws:

InterruptedException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Heartbeat