Class CommitMetadataManager
java.lang.Object
org.apache.storm.kafka.spout.internal.CommitMetadataManager
Generates and reads commit metadata.
- 
Constructor SummaryConstructorsConstructorDescriptionCommitMetadataManager(TopologyContext context, KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Create a manager with the given context.
- 
Method SummaryModifier and TypeMethodDescriptionbooleanisOffsetCommittedByThisTopology(org.apache.kafka.common.TopicPartition tp, org.apache.kafka.clients.consumer.OffsetAndMetadata committedOffset, Map<org.apache.kafka.common.TopicPartition, OffsetManager> offsetManagers) Checks ifOffsetAndMetadatawas committed by aKafkaSpoutinstance in this topology.
- 
Constructor Details- 
CommitMetadataManagerpublic CommitMetadataManager(TopologyContext context, KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Create a manager with the given context.
 
- 
- 
Method Details- 
isOffsetCommittedByThisTopologypublic boolean isOffsetCommittedByThisTopology(org.apache.kafka.common.TopicPartition tp, org.apache.kafka.clients.consumer.OffsetAndMetadata committedOffset, Map<org.apache.kafka.common.TopicPartition, OffsetManager> offsetManagers) Checks ifOffsetAndMetadatawas committed by aKafkaSpoutinstance in this topology.- Parameters:
- tp- The topic partition the commit metadata belongs to.
- committedOffset-- OffsetAndMetadatainfo committed to Kafka
- offsetManagers- The offset managers.
- Returns:
- true if this topology committed this OffsetAndMetadata, false otherwise
 
- 
getCommitMetadata
 
-