Class KafkaRecordSenderContext

java.lang.Object

io.micrometer.observation.Observation.Context

io.micrometer.observation.transport.SenderContext<org.apache.kafka.clients.producer.ProducerRecord<?,?>>

org.springframework.kafka.support.micrometer.KafkaRecordSenderContext

All Implemented Interfaces:

io.micrometer.observation.Observation.ContextView

public class KafkaRecordSenderContext
extends io.micrometer.observation.transport.SenderContext<org.apache.kafka.clients.producer.ProducerRecord<?,?>>

SenderContext for ProducerRecords.

Since:

3.0

Author:

Gary Russell, Christian Mergenthaler, Wang Zhiyang, Soby Chacko

Constructor Summary

Constructors

Constructor	Description
KafkaRecordSenderContext(org.apache.kafka.clients.producer.ProducerRecord<?,?> record, String beanName, Supplier<String> clusterId)

Method Summary

Modifier and Type	Method	Description
String	getBeanName()	Return the template's bean name.
String	getDestination()	Return the destination topic.
org.apache.kafka.clients.producer.ProducerRecord<?,?>	getRecord()	Return the producer record.

Methods inherited from class io.micrometer.observation.transport.SenderContext

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

Methods inherited from class 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.micrometer.observation.Observation.ContextView

getOrDefault

Constructor Details

KafkaRecordSenderContext

public KafkaRecordSenderContext(org.apache.kafka.clients.producer.ProducerRecord<?,?> record,
 String beanName,
 Supplier<String> clusterId)

Method Details

getBeanName

public String getBeanName()

Return the template's bean name.

Returns:

the name.

getDestination

public String getDestination()

Return the destination topic.

Returns:

the topic.

getRecord

public org.apache.kafka.clients.producer.ProducerRecord<?,?> getRecord()

Return the producer record.

Returns:

the record.

Since:

3.0.6