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

    Constructors
    Constructor
    Description
    KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, String listenerId, Supplier<String> clusterId)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    Return 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, 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

    • KafkaRecordReceiverContext

      public KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, String listenerId, Supplier<String> clusterId)
  • Method Details

    • getListenerId

      public String getListenerId()
      Return the listener id.
      Returns:
      the listener id.
    • getSource

      public String 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