クラス MicrometerConsumerListener<K,V>
java.lang.ObjectSE
org.springframework.kafka.core.MicrometerConsumerListener<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- 実装されたすべてのインターフェース:
ConsumerFactory.Listener<K,
V>
public class MicrometerConsumerListener<K,V>
extends ObjectSE
implements ConsumerFactory.Listener<K,V>
KafkaClientMetrics
を管理するコンシューマーファクトリリスナー。- 導入:
- 2.5
- 作成者:
- Gary Russell
コンストラクターのサマリー
コンストラクターコンストラクター説明MicrometerConsumerListener
(io.micrometer.core.instrument.MeterRegistry meterRegistry) 提供されたレジストリを使用してインスタンスを構築します。MicrometerConsumerListener
(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags) 提供されたレジストリとタグを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明void
consumerAdded
(StringSE id, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) 新しいコンシューマーが作成されました。void
consumerRemoved
(StringSE id, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) 既存のコンシューマーが削除されました。
コンストラクターの詳細
MicrometerConsumerListener
public MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry) 提供されたレジストリを使用してインスタンスを構築します。- パラメーター:
meterRegistry
- レジストリ。
MicrometerConsumerListener
public MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags) 提供されたレジストリとタグを使用してインスタンスを構築します。- パラメーター:
meterRegistry
- レジストリ。tags
- タグ。
メソッドの詳細
consumerAdded
インターフェースからコピーされた説明:ConsumerFactory.Listener
新しいコンシューマーが作成されました。- 次で指定:
- インターフェース
ConsumerFactory.Listener<K,
のV> consumerAdded
- パラメーター:
id
- コンシューマー ID(ピリオドで区切られたファクトリ Bean 名と client.id)。consumer
- コンシューマー。
consumerRemoved
インターフェースからコピーされた説明:ConsumerFactory.Listener
既存のコンシューマーが削除されました。- 次で指定:
- インターフェース
ConsumerFactory.Listener<K,
のV> consumerRemoved
- パラメーター:
id
- コンシューマー ID(ピリオドで区切られたファクトリ Bean 名と client.id)。consumer
- コンシューマー。