クラス 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<?,?>>
ConsumerRecord
s の ReceiverContext
。- 導入:
- 3.0
- 作成者:
- Gary Russell, Christian Mergenthaler, Wang Zhiyang
コンストラクターのサマリー
コンストラクターコンストラクター説明KafkaRecordReceiverContext
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, StringSE listenerId, StringSE clientId, StringSE groupId, SupplierSE<StringSE> clusterId) Kafka レコードレシーバーコンテキストを構築します。KafkaRecordReceiverContext
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, StringSE listenerId, SupplierSE<StringSE> clusterId) Kafka レコードレシーバーコンテキストを構築します。メソッドのサマリー
修飾子と型メソッド説明クライアント ID を返します。コンシューマーグループ ID を返します。リスナー ID を返します。オフセットを返します。パーティションを戻します。org.apache.kafka.clients.consumer.ConsumerRecord<?,
?> コンシューマーレコードを返します。ソーストピックを返します。クラス 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, StringSE clientId, StringSE groupId, SupplierSE<StringSE> clusterId) Kafka レコードレシーバーコンテキストを構築します。- パラメーター:
record
- コンシューマー記録。listenerId
- コンテナーのリスナー ID。clientId
- kafka クライアント ID。groupId
- コンシューマーグループ ID。clusterId
- kafka クラスター ID。- 導入:
- 3.2
メソッドの詳細
getListenerId
リスナー ID を返します。- 戻り値:
- リスナー ID。
getGroupId
コンシューマーグループ ID を返します。- 戻り値:
- コンシューマーグループ ID。
- 導入:
- 3.2
getClientId
クライアント ID を返します。- 戻り値:
- クライアント ID。
- 導入:
- 3.2
getSource
ソーストピックを返します。- 戻り値:
- ソース。
getRecord
public org.apache.kafka.clients.consumer.ConsumerRecord<?,?> getRecord()コンシューマーレコードを返します。- 戻り値:
- レコード。
- 導入:
- 3.0.6
getPartition
パーティションを戻します。- 戻り値:
- パーティション。
- 導入:
- 3.2
getOffset
オフセットを返します。- 戻り値:
- オフセット。
- 導入:
- 3.2