reactor.kafka.sender.observation

Class KafkaRecordSenderContext

java.lang.Object

io.micrometer.observation.Observation.Context

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

reactor.kafka.sender.observation.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:

1.4

Constructor Summary

Constructors

Constructor and Description
KafkaRecordSenderContext(org.apache.kafka.clients.producer.ProducerRecord<?,?> record, String producerId, String kafkaServers)

Method Summary

Modifier and Type	Method and Description
String	getDestination() Return the destination topic.
String	getProducerId()

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

Constructor Detail

KafkaRecordSenderContext

public KafkaRecordSenderContext(org.apache.kafka.clients.producer.ProducerRecord<?,?> record,
                                String producerId,
                                String kafkaServers)

Method Detail

getProducerId

public String getProducerId()

getDestination

public String getDestination()

Return the destination topic.

Returns:

the topic.