Uses of Class
org.apache.storm.kafka.spout.internal.OffsetManager
-
Uses of OffsetManager in org.apache.storm.kafka.spout.internal
Modifier and TypeMethodDescriptionboolean
CommitMetadataManager.isOffsetCommittedByThisTopology
(org.apache.kafka.common.TopicPartition tp, org.apache.kafka.clients.consumer.OffsetAndMetadata committedOffset, Map<org.apache.kafka.common.TopicPartition, OffsetManager> offsetManagers) Checks ifOffsetAndMetadata
was committed by aKafkaSpout
instance in this topology. -
Uses of OffsetManager in org.apache.storm.kafka.spout.metrics2
ModifierConstructorDescriptionKafkaOffsetMetricManager
(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.consumer.Consumer<K, V>> consumerSupplier, TopologyContext topologyContext) KafkaOffsetPartitionMetrics
(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.consumer.Consumer<K, V>> consumerSupplier, org.apache.kafka.common.TopicPartition topicPartition, KafkaOffsetTopicMetrics topicMetrics)