Class Checkpoint

java.lang.Object
org.apache.kafka.connect.mirror.Checkpoint

public class Checkpoint extends Object
Checkpoint records emitted from MirrorCheckpointConnector. Encodes remote consumer group state.
  • Field Details

  • Constructor Details

    • Checkpoint

      public Checkpoint(String consumerGroupId, TopicPartition topicPartition, long upstreamOffset, long downstreamOffset, String metadata)
  • Method Details

    • consumerGroupId

      public String consumerGroupId()
    • topicPartition

      public TopicPartition topicPartition()
    • upstreamOffset

      public long upstreamOffset()
    • downstreamOffset

      public long downstreamOffset()
    • metadata

      public String metadata()
    • offsetAndMetadata

      public OffsetAndMetadata offsetAndMetadata()
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • deserializeRecord

      public static Checkpoint deserializeRecord(ConsumerRecord<byte[],byte[]> record)
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object