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

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

clone, equals, finalize, 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)