クラス KafkaRecordReceiverContext

java.lang.ObjectSE
io.micrometer.observation.Observation.Context
io.micrometer.observation.transport.ReceiverContext<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
実装されているすべてのインターフェース:
io.micrometer.observation.Observation.ContextView
public class KafkaRecordReceiverContext extends io.micrometer.observation.transport.ReceiverContext<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
 ConsumerRecords の ReceiverContext。
導入:
3.0
作成者:
Gary Russell, Christian Mergenthaler, Wang Zhiyang

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

    コンストラクター
    コンストラクター
    説明
    KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, StringSE listenerId, @Nullable StringSE clientId, @Nullable StringSE groupId, SupplierSE<StringSE> clusterId)
    Kafka レコードレシーバーコンテキストを構築します。
    KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, StringSE listenerId, SupplierSE<StringSE> clusterId)
    Kafka レコードレシーバーコンテキストを構築します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    @Nullable StringSE
    getClientId()
    クライアント ID を返します。
    @Nullable StringSE
    getGroupId()
    コンシューマーグループ ID を返します。
    StringSE
    getListenerId()
    リスナー ID を返します。
    StringSE
    getOffset()
    オフセットを返します。
    StringSE
    getPartition()
    パーティションを戻します。
    org.apache.kafka.clients.consumer.ConsumerRecord<?,?>
    getRecord()
    コンシューマーレコードを返します。
    StringSE
    getSource()
    ソーストピックを返します。

    クラス io.micrometer.observation.transport.ReceiverContext から継承されたメソッド

    getCarrier, getGetter, getKind, getRemoteServiceAddress, getRemoteServiceName, setCarrier, setRemoteServiceAddress, setRemoteServiceName

    クラス io.micrometer.observation.Observation.Context から継承されたメソッド

    addHighCardinalityKeyValue, addHighCardinalityKeyValues, addLowCardinalityKeyValue, addLowCardinalityKeyValues, clear, computeIfAbsent, containsKey, get, getAllKeyValues, getContextualName, getError, getHighCardinalityKeyValue, getHighCardinalityKeyValues, getLowCardinalityKeyValue, getLowCardinalityKeyValues, getName, getOrDefault, getParentObservation, getRequired, put, remove, removeHighCardinalityKeyValue, removeHighCardinalityKeyValues, removeLowCardinalityKeyValue, removeLowCardinalityKeyValues, setContextualName, setError, setName, setParentObservation, toString

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

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

    インターフェース io.micrometer.observation.Observation.ContextView から継承されたメソッド

    getOrDefault

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

    • KafkaRecordReceiverContext

      public KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, StringSE listenerId, SupplierSE<StringSE> clusterId)
      Kafka レコードレシーバーコンテキストを構築します。
      パラメーター:
      record - コンシューマー記録。
      listenerId - コンテナーのリスナー ID。
      clusterId - kafka クラスター ID。

    • KafkaRecordReceiverContext

      public KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, StringSE listenerId, @Nullable StringSE clientId, @Nullable StringSE groupId, SupplierSE<StringSE> clusterId)
      Kafka レコードレシーバーコンテキストを構築します。
      パラメーター:
      record - コンシューマー記録。
      listenerId - コンテナーのリスナー ID。
      clientId - kafka クライアント ID。
      groupId - コンシューマーグループ ID。
      clusterId - kafka クラスター ID。
      導入:
      3.2

  • メソッドの詳細

    • getListenerId

      public StringSE getListenerId()
      リスナー ID を返します。
      戻り値:
      リスナー ID。

    • getGroupId

      public @Nullable StringSE getGroupId()
      コンシューマーグループ ID を返します。
      戻り値:
      コンシューマーグループ ID。
      導入:
      3.2

    • getClientId

      public @Nullable StringSE getClientId()
      クライアント ID を返します。
      戻り値:
      クライアント ID。
      導入:
      3.2

    • getSource

      public StringSE getSource()
      ソーストピックを返します。
      戻り値:
      ソース。

    • getRecord

      public org.apache.kafka.clients.consumer.ConsumerRecord<?,?> getRecord()
      コンシューマーレコードを返します。
      戻り値:
      レコード。
      導入:
      3.0.6

    • getPartition

      public StringSE getPartition()
      パーティションを戻します。
      戻り値:
      パーティション。
      導入:
      3.2

    • getOffset

      public StringSE getOffset()
      オフセットを返します。
      戻り値:
      オフセット。
      導入:
      3.2