org.apache.kafka.connect.mirror

Class Heartbeat

java.lang.Object

org.apache.kafka.connect.mirror.Heartbeat

public class Heartbeat
extends Object

Heartbeat message sent from MirrorHeartbeatTask to target cluster. Heartbeats are always replicated.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

Heartbeat

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

Method Detail

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)