Class KafkaRecordReceiverContext
java.lang.Object
io.micrometer.observation.Observation.Context
io.micrometer.observation.transport.ReceiverContext<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
- All Implemented Interfaces:
io.micrometer.observation.Observation.ContextView
public class KafkaRecordReceiverContext
extends io.micrometer.observation.transport.ReceiverContext<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
ReceiverContext for ConsumerRecords.- Since:
- 3.0
- Author:
- Gary Russell
-
Constructor Summary
ConstructorsConstructorDescriptionKafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, String listenerId, Supplier<String> clusterId) -
Method Summary
Modifier and TypeMethodDescriptionReturn the listener id.org.apache.kafka.clients.consumer.ConsumerRecord<?,?> Return the consumer record.Return the source topic.Methods inherited from class io.micrometer.observation.transport.ReceiverContext
getCarrier, getGetter, getKind, getRemoteServiceAddress, getRemoteServiceName, 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface io.micrometer.observation.Observation.ContextView
getOrDefault
-
Constructor Details
-
KafkaRecordReceiverContext
-
-
Method Details
-
getListenerId
Return the listener id.- Returns:
- the listener id.
-
getSource
Return the source topic.- Returns:
- the source.
-
getRecord
public org.apache.kafka.clients.consumer.ConsumerRecord<?,?> getRecord()Return the consumer record.- Returns:
- the record the record.
- Since:
- 3.0.6
-