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

クラス KafkaStreamsMicrometerListener

java.lang.ObjectSE
org.springframework.kafka.streams.KafkaStreamsMicrometerListener
実装されたすべてのインターフェース:
StreamsBuilderFactoryBean.Listener
public class KafkaStreamsMicrometerListener extends ObjectSE implements StreamsBuilderFactoryBean.Listener
KafkaStreams の KafkaStreamsMetrics を作成します。
導入:
2.5.3
作成者:
Gary Russell

  • コンストラクターのサマリー

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

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    streamsAdded(StringSE id, org.apache.kafka.streams.KafkaStreams kafkaStreams)
    新しい KafkaStreams が作成されました。
    void
    streamsRemoved(StringSE id, org.apache.kafka.streams.KafkaStreams streams)
    既存の KafkaStreams が削除されました。

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

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

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

    • KafkaStreamsMicrometerListener

      public KafkaStreamsMicrometerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)
      提供されたレジストリを使用してインスタンスを構築します。
      パラメーター:
      meterRegistry - レジストリ。

    • KafkaStreamsMicrometerListener

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

  • メソッドの詳細

    • streamsAdded

      public void streamsAdded(StringSE id, org.apache.kafka.streams.KafkaStreams kafkaStreams)
      インターフェースからコピーされた説明: StreamsBuilderFactoryBean.Listener
      新しい KafkaStreams が作成されました。
      次で指定:
      インターフェース StreamsBuilderFactoryBean.Listener の streamsAdded 
      パラメーター:
      id - ストリーム ID（ファクトリの Bean 名）。
      kafkaStreams - ストリーム ;

    • streamsRemoved

      public void streamsRemoved(StringSE id, org.apache.kafka.streams.KafkaStreams streams)
      インターフェースからコピーされた説明: StreamsBuilderFactoryBean.Listener
      既存の KafkaStreams が削除されました。
      次で指定:
      インターフェース StreamsBuilderFactoryBean.Listener の streamsRemoved 
      パラメーター:
      id - ストリーム ID（ファクトリの Bean 名）。
      streams - ストリーム ;