クラス KafkaMetricsSupport<C>

java.lang.ObjectSE
org.springframework.kafka.core.KafkaMetricsSupport<C>
型パラメーター:
C - Kafka クライアント型。
既知の直属サブクラス
KafkaStreamsMicrometerListener、MicrometerConsumerListener、MicrometerProducerListener
public abstract class KafkaMetricsSupport<C> extends ObjectSE
KafkaClientMetrics を管理するための抽象クラス。
導入:
3.3
作成者:
Artem Bilan
関連事項:
  • KafkaClientMetrics

  • フィールドのサマリー

    フィールド
    修飾子と型
    フィールド
    説明
    protected final io.micrometer.core.instrument.MeterRegistry
    meterRegistry
    protected final @Nullable ScheduledExecutorServiceSE
    scheduler
    protected final ListSE<io.micrometer.core.instrument.Tag>
    tags

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

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

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    protected final void
    bindClient(StringSE id, C client)
    指定された ID を使用して Apache Kafka クライアントのメトリクスをバインドします。
    protected io.micrometer.core.instrument.binder.MeterBinder
    createClientMetrics(C client, ListSE<io.micrometer.core.instrument.Tag> tags)
    提供された Kafka クライアントおよびメトリクスタグの io.micrometer.core.instrument.binder.kafka.KafkaMetrics インスタンスを作成します。
    protected final void
    unbindClient(@Nullable StringSE id, C client)
    提供された Kafka クライアントの io.micrometer.core.instrument.binder.kafka.KafkaMetrics をアンバインドします。

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

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

  • フィールドの詳細

    • meterRegistry

      protected final io.micrometer.core.instrument.MeterRegistry meterRegistry

    • tags

      protected final ListSE<io.micrometer.core.instrument.Tag> tags

    • scheduler

      protected final @Nullable ScheduledExecutorServiceSE scheduler

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

    • KafkaMetricsSupport

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

    • KafkaMetricsSupport

      protected KafkaMetricsSupport(io.micrometer.core.instrument.MeterRegistry meterRegistry, TaskScheduler taskScheduler)
      提供された MeterRegistry および TaskScheduler を使用してインスタンスを構築します。
      パラメーター:
      meterRegistry - レジストリ。
      taskScheduler - タスクスケジューラ。

    • KafkaMetricsSupport

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

    • KafkaMetricsSupport

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

  • メソッドの詳細

    • bindClient

      protected final void bindClient(StringSE id, C client)
      指定された ID を使用して Apache Kafka クライアントのメトリクスをバインドします。
      パラメーター:
      id - ストア内でクライアントが管理する一意の識別子。
      client - バインドする Kafka クライアントインスタンス。

    • createClientMetrics

      protected io.micrometer.core.instrument.binder.MeterBinder createClientMetrics(C client, ListSE<io.micrometer.core.instrument.Tag> tags)
      提供された Kafka クライアントおよびメトリクスタグの io.micrometer.core.instrument.binder.kafka.KafkaMetrics インスタンスを作成します。デフォルトでは、このファクトリは Consumer、Producer、AdminClient 型を認識します。他のユースケースでは、このメソッドをオーバーライドできます。
      パラメーター:
      client - io.micrometer.core.instrument.binder.kafka.KafkaMetrics インスタンスを作成するクライアント。
      tags - io.micrometer.core.instrument.binder.kafka.KafkaMetrics のタグ。
      戻り値:
      io.micrometer.core.instrument.binder.kafka.KafkaMetrics

    • unbindClient

      protected final void unbindClient(@Nullable StringSE id, C client)
      提供された Kafka クライアントの io.micrometer.core.instrument.binder.kafka.KafkaMetrics をアンバインドします。
      パラメーター:
      id - ストア内でクライアントが管理する一意の識別子。
      client - Kafka クライアントインスタンスをアンバインドします。