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

クラス MicrometerConsumerListener<K,V>

java.lang.ObjectSE
org.springframework.kafka.core.KafkaMetricsSupport<org.apache.kafka.clients.consumer.Consumer<K,V>>
org.springframework.kafka.core.MicrometerConsumerListener<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
ConsumerFactory.Listener<K,V>
public class MicrometerConsumerListener<K,V> extends KafkaMetricsSupport<org.apache.kafka.clients.consumer.Consumer<K,V>> implements ConsumerFactory.Listener<K,V>
KafkaClientMetrics を管理するコンシューマーファクトリリスナー。
導入:
2.5
作成者:
Gary Russell, Artem Bilan

  • フィールドのサマリー

    クラス org.springframework.kafka.core.KafkaMetricsSupport から継承されたフィールド

    meterRegistry, scheduler, tags

  • コンストラクターの概要

    コンストラクター
    コンストラクター
    説明
    MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)
    提供されたレジストリを使用してインスタンスを構築します。
    MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags)
    提供されたレジストリとタグを使用してインスタンスを構築します。
    MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags, TaskScheduler taskScheduler)
    提供されたレジストリ、タグ、タスクスケジューラを使用してインスタンスを構築します。
    MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, TaskScheduler taskScheduler)
    提供されたレジストリとタスクスケジューラを使用してインスタンスを構築します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    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)
    既存のコンシューマーが削除されました。

    クラス org.springframework.kafka.core.KafkaMetricsSupport から継承されたメソッド

    bindClient, createClientMetrics, unbindClient

    クラス 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, TaskScheduler taskScheduler)
      提供されたレジストリとタスクスケジューラを使用してインスタンスを構築します。
      パラメーター:
      meterRegistry - レジストリ。
      taskScheduler - タスクスケジューラ。
      導入:
      3.3

    • MicrometerConsumerListener

      public MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags)
      提供されたレジストリとタグを使用してインスタンスを構築します。
      パラメーター:
      meterRegistry - レジストリ。
      tags - タグ。

    • MicrometerConsumerListener

      public MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, ListSE<io.micrometer.core.instrument.Tag> tags, TaskScheduler taskScheduler)
      提供されたレジストリ、タグ、タスクスケジューラを使用してインスタンスを構築します。
      パラメーター:
      meterRegistry - レジストリ。
      tags - タグ。
      taskScheduler - タスクスケジューラ。
      導入:
      3.3

  • メソッドの詳細

    • 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 - コンシューマー。