public class KRaftSnapshotMetrics extends Object implements AutoCloseable
Constructor and Description |
---|
KRaftSnapshotMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.kafka.common.metrics.Sensor |
deleteLatencySensor() |
org.apache.kafka.common.metrics.Sensor |
putLatencySensor() |
void |
updateError(boolean errorValue) |
void |
updateLastUploadMs(long timeMs) |
public KRaftSnapshotMetrics(org.apache.kafka.common.metrics.Metrics metrics)
public void updateLastUploadMs(long timeMs)
public org.apache.kafka.common.metrics.Sensor putLatencySensor()
public org.apache.kafka.common.metrics.Sensor deleteLatencySensor()
public void updateError(boolean errorValue)
public void close() throws Exception
close
in interface AutoCloseable
Exception