public class CatalogMetrics extends Object
Modifier and Type | Class and Description |
---|---|
static class |
CatalogMetrics.LongGauge |
Modifier and Type | Field and Description |
---|---|
static String |
ACTIVE_COLLECTOR |
static String |
ACTIVE_COLLECTOR_DOC |
static String |
CACHED_TOPICS_TOTAL |
static String |
CACHED_TOPICS_TOTAL_DOC |
org.apache.kafka.common.MetricName |
cachedTopicsMetricName |
static String |
COLLECTOR_EVENT_HANDLE_ERROR |
static String |
COLLECTOR_EVENT_HANDLE_ERROR_DOC |
org.apache.kafka.common.metrics.Sensor |
collectorEventHandleErrorSensor |
static String |
DELTA_EVENT_EMIT |
static String |
DELTA_EVENT_EMIT_DOC |
org.apache.kafka.common.metrics.Sensor |
deltaEventEmitSensor |
static String |
GROUP_NAME |
static String |
SNAPSHOT_EMITTING_DELAY_MS |
static String |
SNAPSHOT_EMITTING_DELAY_MS_DOC |
static String |
SNAPSHOT_EVENT_EMIT |
static String |
SNAPSHOT_EVENT_EMIT_DOC |
org.apache.kafka.common.MetricName |
snapshotDelayMsMetricName |
CatalogMetrics.LongGauge |
snapshotEmittingDelayMsMetric |
org.apache.kafka.common.metrics.Sensor |
snapshotEventEmitSensor |
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 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 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