public class TierTopicSnapshotMetrics extends Object
Modifier and Type | Field and Description |
---|---|
static String |
ACTIVE_STATE_INDICATOR_PREFIX |
static String |
CONSUMER_LAG_METRIC_PREFIX |
static String |
FAILURE_METRIC_PREFIX |
static String |
TTPS_SNAPSHOT_UPLOADED_PREFIX |
Constructor and Description |
---|
TierTopicSnapshotMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
deRegister() |
void |
markTTPSActive() |
void |
markTTPSInActive() |
void |
recordConsumerLag(long lag) |
void |
recordSnapshotManagerFailure() |
void |
recordSnapshotUpload() |
public static final String ACTIVE_STATE_INDICATOR_PREFIX
public static final String CONSUMER_LAG_METRIC_PREFIX
public static final String FAILURE_METRIC_PREFIX
public static final String TTPS_SNAPSHOT_UPLOADED_PREFIX
public TierTopicSnapshotMetrics(org.apache.kafka.common.metrics.Metrics metrics)
public void deRegister()
public void markTTPSActive()
public void markTTPSInActive()
public void recordSnapshotUpload()
public void recordSnapshotManagerFailure()
public void recordConsumerLag(long lag)