Class CommitMetadataManager

java.lang.Object
org.apache.storm.kafka.spout.internal.CommitMetadataManager

public final class CommitMetadataManager extends Object
Generates and reads commit metadata.
  • Constructor Details

  • Method Details

    • isOffsetCommittedByThisTopology

      public boolean isOffsetCommittedByThisTopology(org.apache.kafka.common.TopicPartition tp, org.apache.kafka.clients.consumer.OffsetAndMetadata committedOffset, Map<org.apache.kafka.common.TopicPartition,OffsetManager> offsetManagers)
      Checks if OffsetAndMetadata was committed by a KafkaSpout instance in this topology.
      Parameters:
      tp - The topic partition the commit metadata belongs to.
      committedOffset - OffsetAndMetadata info committed to Kafka
      offsetManagers - The offset managers.
      Returns:
      true if this topology committed this OffsetAndMetadata, false otherwise
    • getCommitMetadata

      public String getCommitMetadata()