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)