reactor.kafka.receiver.observation

Class KafkaRecordReceiverContext

java.lang.Object

io.micrometer.observation.Observation.Context

io.micrometer.observation.transport.ReceiverContext<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>

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

1.4

Constructor Summary

Constructors

Constructor and Description
KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, String receiverId, String kafkaServers)

Method Summary

Modifier and Type	Method and Description
String	getReceiverId()
String	getSource() 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

Constructor Detail

KafkaRecordReceiverContext

public KafkaRecordReceiverContext(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record,
                                  String receiverId,
                                  String kafkaServers)

Method Detail

getReceiverId

public String getReceiverId()

getSource

public String getSource()

Return the source topic.

Returns:

the source.