public class KafkaStreamsMicrometerListener extends java.lang.Object implements StreamsBuilderFactoryBean.Listener
KafkaStreamsMetrics for the KafkaStreams.| Constructor and 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.
|
| Modifier and Type | Method and 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. |
public KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)
meterRegistry - the registry.public KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry,
java.util.List<io.micrometer.core.instrument.Tag> tags)
meterRegistry - the registry.tags - the tags.public void streamsAdded(java.lang.String id,
org.apache.kafka.streams.KafkaStreams kafkaStreams)
StreamsBuilderFactoryBean.ListenerKafkaStreams was created.streamsAdded in interface StreamsBuilderFactoryBean.Listenerid - the streams id (factory bean name).kafkaStreams - the streams;public void streamsRemoved(java.lang.String id,
org.apache.kafka.streams.KafkaStreams streams)
StreamsBuilderFactoryBean.ListenerKafkaStreams was removed.streamsRemoved in interface StreamsBuilderFactoryBean.Listenerid - the streams id (factory bean name).streams - the streams;