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

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

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

    Constructor parameters in org.apache.storm.kafka.spout.metrics with type arguments of type OffsetManager
    Constructor and Description
    `KafkaOffsetMetric(Supplier<Map<org.apache.kafka.common.TopicPartition,OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.consumer.Consumer<K,V>> consumerSupplier)`

Copyright © 2019 The Apache Software Foundation. All rights reserved.