Package org.apache.kafka.streams.internals.metrics

Class ClientMetrics

java.lang.Object

org.apache.kafka.streams.internals.metrics.ClientMetrics

public class ClientMetrics
extends Object

Method Summary

Modifier and Type	Method	Description
static void	addApplicationIdMetric(StreamsMetricsImpl streamsMetrics, String applicationId)
static void	addCommitIdMetric(StreamsMetricsImpl streamsMetrics)
static void	addNumAliveStreamThreadMetric(StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Gauge<Integer> stateProvider)
static void	addStateMetric(StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Gauge<KafkaStreams.State> stateProvider)
static void	addTopologyDescriptionMetric(StreamsMetricsImpl streamsMetrics, String topologyDescription)
static void	addVersionMetric(StreamsMetricsImpl streamsMetrics)
static String	commitId()
static String	version()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

version

public static String version()

commitId

public static String commitId()

addVersionMetric

public static void addVersionMetric(StreamsMetricsImpl streamsMetrics)

addCommitIdMetric

public static void addCommitIdMetric(StreamsMetricsImpl streamsMetrics)

addApplicationIdMetric

public static void addApplicationIdMetric(StreamsMetricsImpl streamsMetrics,
                                          String applicationId)

addTopologyDescriptionMetric

public static void addTopologyDescriptionMetric(StreamsMetricsImpl streamsMetrics,
                                                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<Integer> stateProvider)