クラス KafkaRecordSenderContext
java.lang.ObjectSE
io.micrometer.observation.Observation.Context
io.micrometer.observation.transport.SenderContext<org.apache.kafka.clients.producer.ProducerRecord<?,?>>
org.springframework.kafka.support.micrometer.KafkaRecordSenderContext
- 実装されたすべてのインターフェース:
io.micrometer.observation.Observation.ContextView
public class KafkaRecordSenderContext
extends io.micrometer.observation.transport.SenderContext<org.apache.kafka.clients.producer.ProducerRecord<?,?>>
ProducerRecord
s の SenderContext
。- 導入:
- 3.0
- 作成者:
- Gary Russell, Christian Mergenthaler, Wang Zhiyang
コンストラクターのサマリー
コンストラクターコンストラクター説明KafkaRecordSenderContext
(org.apache.kafka.clients.producer.ProducerRecord<?, ?> record, StringSE beanName, SupplierSE<StringSE> clusterId) メソッドのサマリー
修飾子と型メソッド説明テンプレートの Bean 名を返します。宛先トピックを返します。org.apache.kafka.clients.producer.ProducerRecord<?,
?> プロデューサーのレコードを返します。クラス io.micrometer.observation.transport.SenderContext から継承されたメソッド
getCarrier, getKind, getRemoteServiceAddress, getRemoteServiceName, getSetter, 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
コンストラクターの詳細
KafkaRecordSenderContext
public KafkaRecordSenderContext(org.apache.kafka.clients.producer.ProducerRecord<?, ?> record, StringSE beanName, SupplierSE<StringSE> clusterId)
メソッドの詳細
getBeanName
テンプレートの Bean 名を返します。- 戻り値:
- 名前。
getDestination
宛先トピックを返します。- 戻り値:
- トピック。
getRecord
public org.apache.kafka.clients.producer.ProducerRecord<?,?> getRecord()プロデューサーのレコードを返します。- 戻り値:
- レコード。
- 導入:
- 3.0.6