public class CatalogMetrics extends Object
Modifier and Type | Class and Description |
---|---|
static class |
CatalogMetrics.LongGauge |
Constructor and Description |
---|
CatalogMetrics(org.apache.kafka.common.metrics.Metrics metrics,
Supplier<Integer> localStoreSizeSupplier) |
Modifier and Type | Method and Description |
---|---|
void |
removeCatalogMetrics() |
public static final String GROUP_NAME
public static final String ACTIVE_COLLECTOR
public static final String ACTIVE_COLLECTOR_DOC
public static final String CACHED_TOPICS_TOTAL
public static final String CACHED_TOPICS_TOTAL_DOC
public static final String CACHED_ENTITIES_TOTAL
public static final String CACHED_ENTITIES_TOTAL_DOC
public static final String SNAPSHOT_EMITTING_DELAY_MS
public static final String SNAPSHOT_EMITTING_DELAY_MS_DOC
public static final String DELTA_EVENT_EMIT
public static final String DELTA_EVENT_EMIT_DOC
public static final String SNAPSHOT_EVENT_EMIT
public static final String SNAPSHOT_EVENT_EMIT_DOC
public static final String COLLECTOR_EVENT_HANDLE_ERROR
public static final String COLLECTOR_EVENT_HANDLE_ERROR_DOC
public final org.apache.kafka.common.MetricName cachedTopicsMetricName
public final org.apache.kafka.common.MetricName cachedEntitiesMetricName
public final org.apache.kafka.common.MetricName snapshotDelayMsMetricName
public final CatalogMetrics.LongGauge snapshotEmittingDelayMsMetric
public final org.apache.kafka.common.metrics.Sensor deltaEventEmitSensor
public final org.apache.kafka.common.metrics.Sensor snapshotEventEmitSensor
public final org.apache.kafka.common.metrics.Sensor collectorEventHandleErrorSensor