public class KafkaSpanDecorator extends AbstractMessagingSpanDecorator
Modifier and Type | Field and Description |
---|---|
static String |
KAFKA_KEY_TAG |
static String |
KAFKA_OFFSET_TAG |
static String |
KAFKA_PARTITION_KEY_TAG |
static String |
KAFKA_PARTITION_TAG |
protected static String |
KEY |
protected static String |
OFFSET |
protected static String |
PARTITION |
protected static String |
PARTITION_KEY
Constants copied from
org.apache.camel.component.kafka.KafkaConstants |
protected static String |
TOPIC |
MESSAGE_BUS_ID
CAMEL_COMPONENT, DEFAULT
Constructor and Description |
---|
KafkaSpanDecorator() |
Modifier and Type | Method and Description |
---|---|
String |
getComponent()
The camel component associated with the decorator.
|
String |
getDestination(org.apache.camel.Exchange exchange,
org.apache.camel.Endpoint endpoint)
This method identifies the destination from the supplied exchange and/or endpoint.
|
void |
pre(io.opentracing.Span span,
org.apache.camel.Exchange exchange,
org.apache.camel.Endpoint endpoint)
This method adds appropriate details (tags/logs) to the supplied span
based on the pre processing of the exchange.
|
getInitiatorSpanKind, getMessageId, getOperationName, getReceiverSpanKind
newSpan, post, stripSchemeAndOptions, toQueryParameters
public static final String KAFKA_PARTITION_TAG
public static final String KAFKA_PARTITION_KEY_TAG
public static final String KAFKA_KEY_TAG
public static final String KAFKA_OFFSET_TAG
protected static final String PARTITION_KEY
org.apache.camel.component.kafka.KafkaConstants
protected static final String PARTITION
protected static final String KEY
protected static final String TOPIC
protected static final String OFFSET
public String getComponent()
SpanDecorator
public String getDestination(org.apache.camel.Exchange exchange, org.apache.camel.Endpoint endpoint)
AbstractMessagingSpanDecorator
getDestination
in class AbstractMessagingSpanDecorator
exchange
- The exchangeendpoint
- The endpointpublic void pre(io.opentracing.Span span, org.apache.camel.Exchange exchange, org.apache.camel.Endpoint endpoint)
SpanDecorator
pre
in interface SpanDecorator
pre
in class AbstractMessagingSpanDecorator
span
- The spanexchange
- The exchangeendpoint
- The endpointApache Camel