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 booleanCommitMetadataManager. isOffsetCommittedByThisTopology(org.apache.kafka.common.TopicPartition tp, org.apache.kafka.clients.consumer.OffsetAndMetadata committedOffset, Map<org.apache.kafka.common.TopicPartition,OffsetManager> offsetManagers)Checks ifOffsetAndMetadatawas committed by aKafkaSpoutinstance 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)
-