Package io.debezium.heartbeat

Class CompositeHeartbeat

java.lang.Object

io.debezium.heartbeat.CompositeHeartbeat

All Implemented Interfaces:

Heartbeat, Heartbeat.ScheduledHeartbeat, AutoCloseable

public class CompositeHeartbeat
extends Object
implements Heartbeat, Heartbeat.ScheduledHeartbeat

Composite Heartbeat solutions (Queue, Database...) Heartbeat. It executes the heartbeats in chain

Author:

gpanice

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 List<Heartbeat>	heartbeats
private final Heartbeat.ScheduledHeartbeat	scheduledHeartbeat

Fields inherited from interface io.debezium.heartbeat.Heartbeat

DEFAULT_NOOP_HEARTBEAT, HEARTBEAT_INTERVAL, HEARTBEAT_INTERVAL_PROPERTY_NAME, HEARTBEAT_TOPICS_PREFIX

Fields inherited from interface io.debezium.heartbeat.Heartbeat.ScheduledHeartbeat

NOOP_HEARTBEAT

Constructor Summary

Constructors

Constructor	Description
CompositeHeartbeat(Heartbeat.ScheduledHeartbeat scheduledHeartbeat, Heartbeat... heartbeat)
CompositeHeartbeat(Heartbeat.ScheduledHeartbeat scheduledHeartbeat, List<Heartbeat> heartbeats)

Method Summary

Modifier and Type	Method	Description
void	close()
void	emit(Map<String,?> partition, OffsetContext offset)	Generates a heartbeat record unconditionally
void	emitWithDelay(Map<String,?> partition, OffsetContext offset)	Generates a heartbeat record if defined time has elapsed
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)
void	heartbeat(Map<String,?> partition, Heartbeat.OffsetProducer offsetProducer, BlockingConsumer<org.apache.kafka.connect.source.SourceRecord> consumer)	Generates a heartbeat record if defined time has elapsed Replaced by Heartbeat.ScheduledHeartbeat.emitWithDelay(Map, OffsetContext)
void	heartbeat(Map<String,?> partition, Map<String,?> offset, BlockingConsumer<org.apache.kafka.connect.source.SourceRecord> consumer)	Generates a heartbeat record if defined time has elapsed Replaced by Heartbeat.ScheduledHeartbeat.emitWithDelay(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.ScheduledHeartbeat

expired, reset

Field Details

scheduledHeartbeat

private final Heartbeat.ScheduledHeartbeat scheduledHeartbeat

heartbeats

private final List<Heartbeat> heartbeats

Constructor Details

CompositeHeartbeat

public CompositeHeartbeat(Heartbeat.ScheduledHeartbeat scheduledHeartbeat,
 Heartbeat... heartbeat)

CompositeHeartbeat

public CompositeHeartbeat(Heartbeat.ScheduledHeartbeat scheduledHeartbeat,
 List<Heartbeat> heartbeats)

Method Details

heartbeat

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

Description copied from interface: Heartbeat

Generates a heartbeat record if defined time has elapsed Replaced by Heartbeat.ScheduledHeartbeat.emitWithDelay(Map, OffsetContext)

Specified by:

heartbeat 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

Throws:

InterruptedException

heartbeat

public void heartbeat(Map<String,?> partition,
 Heartbeat.OffsetProducer offsetProducer,
 BlockingConsumer<org.apache.kafka.connect.source.SourceRecord> consumer)
               throws InterruptedException

Description copied from interface: Heartbeat

Generates a heartbeat record if defined time has elapsed Replaced by Heartbeat.ScheduledHeartbeat.emitWithDelay(Map, OffsetContext)

Specified by:

heartbeat in interface Heartbeat

Parameters:

partition - partition for the heartbeat record

offsetProducer - lazily calculated offset for the heartbeat record

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

Throws:

InterruptedException

forcedBeat

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

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

Throws:

InterruptedException

emitWithDelay

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

Description copied from interface: Heartbeat.ScheduledHeartbeat

Generates a heartbeat record if defined time has elapsed

Specified by:

emitWithDelay in interface Heartbeat.ScheduledHeartbeat

Parameters:

partition - partition for the heartbeat record

offset - offset for the heartbeat record

Throws:

InterruptedException

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

isEnabled

public boolean isEnabled()

Description copied from interface: Heartbeat

Whether heartbeats are enabled or not.

Specified by:

isEnabled in interface Heartbeat

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Heartbeat