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

クラス 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)
    既存のコンシューマーが削除されました。

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

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

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

    • 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

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

    • consumerRemoved

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