public static class KafkaUtils.KafkaOffsetMetric extends Object implements IMetric
Constructor and Description |
---|
KafkaOffsetMetric(String topic,
DynamicPartitionConnections connections) |
Modifier and Type | Method and Description |
---|---|
Object |
getValueAndReset() |
void |
refreshPartitions(Set<Partition> partitions) |
void |
setLatestEmittedOffset(Partition partition,
long offset) |
public KafkaOffsetMetric(String topic, DynamicPartitionConnections connections)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.