Package 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 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
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Heartbeat
deserializeRecord(ConsumerRecord<byte[],byte[]> record)
String
sourceClusterAlias()
String
targetClusterAlias()
long
timestamp()
String
toString()
-
-
-
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
-
-
Method Detail
-
sourceClusterAlias
public String sourceClusterAlias()
-
targetClusterAlias
public String targetClusterAlias()
-
timestamp
public long timestamp()
-
deserializeRecord
public static Heartbeat deserializeRecord(ConsumerRecord<byte[],byte[]> record)
-
-