Uses of Class
org.apache.storm.kafka.spout.internal.OffsetManager

Packages that use OffsetManager

Package	Description
org.apache.storm.kafka.spout.internal

Uses of OffsetManager in org.apache.storm.kafka.spout.internal

Method parameters in org.apache.storm.kafka.spout.internal with type arguments of type OffsetManager

Modifier and Type	Method and Description
boolean	CommitMetadataManager.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.