クラス KafkaStreamsMicrometerListener
java.lang.ObjectSE
org.springframework.kafka.streams.KafkaStreamsMicrometerListener
- 実装されたすべてのインターフェース:
StreamsBuilderFactoryBean.Listener
public class KafkaStreamsMicrometerListener
extends ObjectSE
implements StreamsBuilderFactoryBean.Listener
KafkaStreams
の KafkaStreamsMetrics
を作成します。- 導入:
- 2.5.3
- 作成者:
- Gary Russell
コンストラクターのサマリー
コンストラクターコンストラクター説明KafkaStreamsMicrometerListener
(io.micrometer.core.instrument.MeterRegistry meterRegistry) 提供されたレジストリを使用してインスタンスを構築します。KafkaStreamsMicrometerListener
(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags) 提供されたレジストリとタグを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明void
streamsAdded
(StringSE id, org.apache.kafka.streams.KafkaStreams kafkaStreams) 新しいKafkaStreams
が作成されました。void
streamsRemoved
(StringSE id, org.apache.kafka.streams.KafkaStreams streams) 既存のKafkaStreams
が削除されました。
コンストラクターの詳細
KafkaStreamsMicrometerListener
public KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry) 提供されたレジストリを使用してインスタンスを構築します。- パラメーター:
meterRegistry
- レジストリ。
KafkaStreamsMicrometerListener
public KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags) 提供されたレジストリとタグを使用してインスタンスを構築します。- パラメーター:
meterRegistry
- レジストリ。tags
- タグ。
メソッドの詳細
streamsAdded
インターフェースからコピーされた説明:StreamsBuilderFactoryBean.Listener
新しいKafkaStreams
が作成されました。- 次で指定:
- インターフェース
StreamsBuilderFactoryBean.Listener
のstreamsAdded
- パラメーター:
id
- ストリーム ID(ファクトリの Bean 名)。kafkaStreams
- ストリーム ;
streamsRemoved
インターフェースからコピーされた説明:StreamsBuilderFactoryBean.Listener
既存のKafkaStreams
が削除されました。- 次で指定:
- インターフェース
StreamsBuilderFactoryBean.Listener
のstreamsRemoved
- パラメーター:
id
- ストリーム ID(ファクトリの Bean 名)。streams
- ストリーム ;