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
  • 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
    Return the template's bean name.
    Return the destination topic.
    org.apache.kafka.clients.producer.ProducerRecord<?,?>
    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