Class Heartbeat


  • public class Heartbeat
    extends Object
    Heartbeat message sent from MirrorHeartbeatTask to target cluster. Heartbeats are always replicated.
    • Field Detail

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