Package org.springframework.kafka.streams

Class KafkaStreamsMicrometerListener

java.lang.Object

org.springframework.kafka.streams.KafkaStreamsMicrometerListener

All Implemented Interfaces:

StreamsBuilderFactoryBean.Listener

public class KafkaStreamsMicrometerListener
extends java.lang.Object
implements StreamsBuilderFactoryBean.Listener

Creates a KafkaStreamsMetrics for the KafkaStreams.

Since:

2.5.3

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)	Construct an instance with the provided registry.
KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, java.util.List<io.micrometer.core.instrument.Tag> tags)	Construct an instance with the provided registry and tags.

Method Summary

Modifier and Type	Method	Description
void	streamsAdded(java.lang.String id, org.apache.kafka.streams.KafkaStreams kafkaStreams)	A new KafkaStreams was created.
void	streamsRemoved(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)	An existing KafkaStreams was removed.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaStreamsMicrometerListener

public KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)

Construct an instance with the provided registry.

Parameters:

meterRegistry - the registry.

KafkaStreamsMicrometerListener

public KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry,
                                      java.util.List<io.micrometer.core.instrument.Tag> tags)

Construct an instance with the provided registry and tags.

Parameters:

meterRegistry - the registry.

tags - the tags.

Method Detail

streamsAdded

public void streamsAdded(java.lang.String id,
                         org.apache.kafka.streams.KafkaStreams kafkaStreams)

Description copied from interface: StreamsBuilderFactoryBean.Listener

A new KafkaStreams was created.

Specified by:

streamsAdded in interface StreamsBuilderFactoryBean.Listener

Parameters:

id - the streams id (factory bean name).

kafkaStreams - the streams;

streamsRemoved

public void streamsRemoved(java.lang.String id,
                           org.apache.kafka.streams.KafkaStreams streams)

Description copied from interface: StreamsBuilderFactoryBean.Listener

An existing KafkaStreams was removed.

Specified by:

streamsRemoved in interface StreamsBuilderFactoryBean.Listener

Parameters:

id - the streams id (factory bean name).

streams - the streams;