クラス 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<?,?>>
ProducerRecords の SenderContext。- 導入:
- 3.0
- 作成者:
- Gary Russell, Christian Mergenthaler, Wang Zhiyang, Soby Chacko
コンストラクターの概要
コンストラクターコンストラクター説明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
getDestination
getRecord
public org.apache.kafka.clients.producer.ProducerRecord<?,?> getRecord()プロデューサーのレコードを返します。- 戻り値:
- レコード。
- 導入:
- 3.0.6