Package org.apache.storm.kafka.spout.metrics2

Class KafkaOffsetMetricManager<K,V>

java.lang.Object

org.apache.storm.kafka.spout.metrics2.KafkaOffsetMetricManager<K,V>

public class KafkaOffsetMetricManager<K,V>
extends Object

This class is used to manage both the partition and topic level offset metrics.

Constructor Summary

Constructors

Constructor	Description
KafkaOffsetMetricManager(Supplier<Map<org.apache.kafka.common.TopicPartition,OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.consumer.Consumer<K,V>> consumerSupplier, TopologyContext topologyContext)

Method Summary

Modifier and Type	Method	Description
Map<String,KafkaOffsetTopicMetrics>	getTopicMetricsMap()
Map<org.apache.kafka.common.TopicPartition,KafkaOffsetPartitionMetrics>	getTopicPartitionMetricsMap()
void	registerMetricsForNewTopicPartitions(Set<org.apache.kafka.common.TopicPartition> newAssignment)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaOffsetMetricManager

public KafkaOffsetMetricManager(Supplier<Map<org.apache.kafka.common.TopicPartition,OffsetManager>> offsetManagerSupplier,
 Supplier<org.apache.kafka.clients.consumer.Consumer<K,V>> consumerSupplier,
 TopologyContext topologyContext)

Method Details

registerMetricsForNewTopicPartitions

public void registerMetricsForNewTopicPartitions(Set<org.apache.kafka.common.TopicPartition> newAssignment)

getTopicPartitionMetricsMap

public Map<org.apache.kafka.common.TopicPartition,KafkaOffsetPartitionMetrics> getTopicPartitionMetricsMap()

getTopicMetricsMap

public Map<String,KafkaOffsetTopicMetrics> getTopicMetricsMap()