Class ClientMetrics
- java.lang.Object
-
- org.apache.kafka.streams.internals.metrics.ClientMetrics
-
public class ClientMetrics extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
addApplicationIdMetric(StreamsMetricsImpl streamsMetrics, java.lang.String applicationId)
static void
addCommitIdMetric(StreamsMetricsImpl streamsMetrics)
static void
addNumAliveStreamThreadMetric(StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Gauge<java.lang.Integer> stateProvider)
static void
addStateMetric(StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Gauge<KafkaStreams.State> stateProvider)
static void
addTopologyDescriptionMetric(StreamsMetricsImpl streamsMetrics, java.lang.String topologyDescription)
static void
addVersionMetric(StreamsMetricsImpl streamsMetrics)
static java.lang.String
commitId()
static java.lang.String
version()
-
-
-
Method Detail
-
version
public static java.lang.String version()
-
commitId
public static java.lang.String commitId()
-
addVersionMetric
public static void addVersionMetric(StreamsMetricsImpl streamsMetrics)
-
addCommitIdMetric
public static void addCommitIdMetric(StreamsMetricsImpl streamsMetrics)
-
addApplicationIdMetric
public static void addApplicationIdMetric(StreamsMetricsImpl streamsMetrics, java.lang.String applicationId)
-
addTopologyDescriptionMetric
public static void addTopologyDescriptionMetric(StreamsMetricsImpl streamsMetrics, java.lang.String topologyDescription)
-
addStateMetric
public static void addStateMetric(StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Gauge<KafkaStreams.State> stateProvider)
-
addNumAliveStreamThreadMetric
public static void addNumAliveStreamThreadMetric(StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Gauge<java.lang.Integer> stateProvider)
-
-