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 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)