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 Details

    • SOURCE_CLUSTER_ALIAS_KEY

      public static final String SOURCE_CLUSTER_ALIAS_KEY
      See Also:

    • TARGET_CLUSTER_ALIAS_KEY

      public static final String TARGET_CLUSTER_ALIAS_KEY
      See Also:

    • TIMESTAMP_KEY

      public static final String TIMESTAMP_KEY
      See Also:

    • VERSION_KEY

      public static final String VERSION_KEY
      See Also:

    • VERSION

      public static final short VERSION
      See Also:

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