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

All Methods Instance Methods Concrete Methods
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;

Class KafkaStreamsMicrometerListener

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

KafkaStreamsMicrometerListener

KafkaStreamsMicrometerListener

Method Detail

streamsAdded

streamsRemoved