public class PartitionMetricSample extends MetricSample<String,PartitionEntity>
entity, sampleTime, valuesByMetricId
Constructor and Description |
---|
PartitionMetricSample(int brokerId,
org.apache.kafka.common.TopicPartition tp) |
Modifier and Type | Method and Description |
---|---|
int |
brokerId()
The id of the broker from which the metrics are from.
|
static PartitionMetricSample |
fromBytes(byte[] bytes) |
byte[] |
toBytes()
This method serialize the metric sample using a simple protocol.
|
String |
toString() |
allMetricValues, close, entity, isValid, metricDefForToString, metricValue, record, sampleTime
public PartitionMetricSample(int brokerId, org.apache.kafka.common.TopicPartition tp)
public int brokerId()
public byte[] toBytes()
public static PartitionMetricSample fromBytes(byte[] bytes) throws UnknownVersionException
UnknownVersionException
public String toString()
toString
in class MetricSample<String,PartitionEntity>