Class KafkaStreamsMicrometerListener
java.lang.Object
org.springframework.kafka.streams.KafkaStreamsMicrometerListener
- All Implemented Interfaces:
StreamsBuilderFactoryBean.Listener
public class KafkaStreamsMicrometerListener
extends Object
implements StreamsBuilderFactoryBean.Listener
Creates a
KafkaStreamsMetrics for the KafkaStreams.- Since:
- 2.5.3
- Author:
- Gary Russell
-
Constructor Summary
ConstructorsConstructorDescriptionKafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry) Construct an instance with the provided registry.KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, List<io.micrometer.core.instrument.Tag> tags) Construct an instance with the provided registry and tags. -
Method Summary
Modifier and TypeMethodDescriptionvoidstreamsAdded(String id, org.apache.kafka.streams.KafkaStreams kafkaStreams) A newKafkaStreamswas created.voidstreamsRemoved(String id, org.apache.kafka.streams.KafkaStreams streams) An existingKafkaStreamswas removed.
-
Constructor Details
-
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, List<io.micrometer.core.instrument.Tag> tags) Construct an instance with the provided registry and tags.- Parameters:
meterRegistry- the registry.tags- the tags.
-
-
Method Details
-
streamsAdded
Description copied from interface:StreamsBuilderFactoryBean.ListenerA newKafkaStreamswas created.- Specified by:
streamsAddedin interfaceStreamsBuilderFactoryBean.Listener- Parameters:
id- the streams id (factory bean name).kafkaStreams- the streams;
-
streamsRemoved
Description copied from interface:StreamsBuilderFactoryBean.ListenerAn existingKafkaStreamswas removed.- Specified by:
streamsRemovedin interfaceStreamsBuilderFactoryBean.Listener- Parameters:
id- the streams id (factory bean name).streams- the streams;
-