public class PartitionMetricSample extends MetricSample<java.lang.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.
|
java.lang.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 java.lang.String toString()
toString
in class MetricSample<java.lang.String,PartitionEntity>