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
-
Constructor Summary
ConstructorsConstructorDescriptionKafkaRecordSenderContext(org.apache.kafka.clients.producer.ProducerRecord<?, ?> record, String beanName, Supplier<String> clusterId) -
Method Summary
Modifier and TypeMethodDescriptionReturn the destination topic.Methods inherited from class io.micrometer.observation.transport.SenderContext
getCarrier, getKind, getRemoteServiceAddress, getRemoteServiceName, getSetter, setCarrier, setRemoteServiceAddress, setRemoteServiceNameMethods 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
-
Constructor Details
-
KafkaRecordSenderContext
-
-
Method Details
-
getBeanName
-
getDestination
Return the destination topic.- Returns:
- the topic.
-