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

Packages that use OffsetManager
Package
Description
org.apache.storm.kafka.spout.internal
org.apache.storm.kafka.spout.metrics2

- ## 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
  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.

- ## Uses of OffsetManager in org.apache.storm.kafka.spout.metrics2

  Constructor parameters in org.apache.storm.kafka.spout.metrics2 with type arguments of type OffsetManager
  Modifier
  Constructor
  Description
  ``
  `KafkaOffsetMetricManager(Supplier<Map<org.apache.kafka.common.TopicPartition,OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, TopologyContext topologyContext)`
  ``
  `KafkaOffsetPartitionMetrics(Supplier<Map<org.apache.kafka.common.TopicPartition,OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, org.apache.kafka.common.TopicPartition topicPartition, KafkaOffsetTopicMetrics topicMetrics)`