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