Package org.apache.kafka.connect.mirror

Class Heartbeat

java.lang.Object

org.apache.kafka.connect.mirror.Heartbeat

public class Heartbeat
extends Object

Heartbeat records emitted by MirrorHeartbeatConnector.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.kafka.common.protocol.types.Schema	HEADER_SCHEMA
static final org.apache.kafka.common.protocol.types.Schema	KEY_SCHEMA
static final String	SOURCE_CLUSTER_ALIAS_KEY
static final String	TARGET_CLUSTER_ALIAS_KEY
static final String	TIMESTAMP_KEY
static final org.apache.kafka.common.protocol.types.Schema	VALUE_SCHEMA_V0
static final short	VERSION
static final String	VERSION_KEY

Constructor Summary

Constructors

Constructor	Description
Heartbeat(String sourceClusterAlias, String targetClusterAlias, long timestamp)

Method Summary

Modifier and Type	Method	Description
static Heartbeat	deserializeRecord(ConsumerRecord<byte[],byte[]> record)
String	sourceClusterAlias()
String	targetClusterAlias()
long	timestamp()
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

SOURCE_CLUSTER_ALIAS_KEY

public static final String SOURCE_CLUSTER_ALIAS_KEY

See Also:

• Constant Field Values

TARGET_CLUSTER_ALIAS_KEY

public static final String TARGET_CLUSTER_ALIAS_KEY

See Also:

• Constant Field Values

TIMESTAMP_KEY

public static final String TIMESTAMP_KEY

See Also:

• Constant Field Values

VERSION_KEY

public static final String VERSION_KEY

See Also:

• Constant Field Values

VERSION

public static final short VERSION

See Also:

• Constant Field Values

VALUE_SCHEMA_V0

public static final org.apache.kafka.common.protocol.types.Schema VALUE_SCHEMA_V0

KEY_SCHEMA

public static final org.apache.kafka.common.protocol.types.Schema KEY_SCHEMA

HEADER_SCHEMA

public static final org.apache.kafka.common.protocol.types.Schema HEADER_SCHEMA

Constructor Details

Heartbeat

public Heartbeat(String sourceClusterAlias,
 String targetClusterAlias,
 long timestamp)

Method Details

sourceClusterAlias

public String sourceClusterAlias()

targetClusterAlias

public String targetClusterAlias()

timestamp

public long timestamp()

toString

public String toString()

Overrides:

toString in class Object

deserializeRecord

public static Heartbeat deserializeRecord(ConsumerRecord<byte[],byte[]> record)