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

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)