パッケージ org.springframework.kafka.core

クラス 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)
    既存のプロデューサーが削除されました。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

  • コンストラクターの詳細

    • 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

      public void producerAdded(StringSE id, org.apache.kafka.clients.producer.Producer<K,V> producer)
      インターフェースからコピーされた説明: ProducerFactory.Listener
      新しいプロデューサーが作成されました。
      次で指定:
      インターフェース ProducerFactory.Listener<K,V> の producerAdded 
      パラメーター:
      id - プロデューサー ID (ピリオドで区切られたファクトリ Bean 名と client.id)。
      producer - プロデューサー。

    • producerRemoved

      public void producerRemoved(StringSE id, org.apache.kafka.clients.producer.Producer<K,V> producer)
      インターフェースからコピーされた説明: ProducerFactory.Listener
      既存のプロデューサーが削除されました。
      次で指定:
      インターフェース ProducerFactory.Listener<K,V> の producerRemoved 
      パラメーター:
      id - プロデューサー ID (ピリオドで区切られたファクトリ Bean 名と client.id)。
      producer - プロデューサー。