Package org.apache.camel.telemetry.decorators

Class KafkaSpanDecorator

java.lang.Object

org.apache.camel.telemetry.decorators.AbstractSpanDecorator

org.apache.camel.telemetry.decorators.AbstractMessagingSpanDecorator

org.apache.camel.telemetry.decorators.KafkaSpanDecorator

All Implemented Interfaces:

SpanDecorator

public class KafkaSpanDecorator
extends AbstractMessagingSpanDecorator

Field Summary

Fields

Modifier and Type	Field	Description
static final String	KAFKA_KEY_TAG
static final String	KAFKA_OFFSET_TAG
static final String	KAFKA_PARTITION_KEY_TAG
static final String	KAFKA_PARTITION_TAG
protected static final String	KEY
protected static final String	OFFSET
protected static final String	OVERRIDE_TOPIC
protected static final String	PARTITION
protected static final String	PARTITION_KEY	Constants copied from invalid reference org.apache.camel.component.kafka.KafkaConstants

Constructor Summary

Constructors

Constructor	Description
KafkaSpanDecorator()

Method Summary

Modifier and Type	Method	Description
void	beforeTracingEvent(Span span, org.apache.camel.Exchange exchange, org.apache.camel.Endpoint endpoint)
String	getComponent()
String	getComponentClassName()
String	getDestination(org.apache.camel.Exchange exchange, org.apache.camel.Endpoint endpoint)	This method identifies the destination from the supplied exchange and/or endpoint.

Methods inherited from class org.apache.camel.telemetry.decorators.AbstractMessagingSpanDecorator

getMessageId, getOperationName

Methods inherited from class org.apache.camel.telemetry.decorators.AbstractSpanDecorator

afterTracingEvent, getExtractor, getInjector, stripSchemeAndOptions, stripSchemeAndOptions, toQueryParameters

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

KAFKA_PARTITION_TAG

public static final String KAFKA_PARTITION_TAG

See Also:

• Constant Field Values

KAFKA_PARTITION_KEY_TAG

public static final String KAFKA_PARTITION_KEY_TAG

See Also:

• Constant Field Values

KAFKA_KEY_TAG

public static final String KAFKA_KEY_TAG

See Also:

• Constant Field Values

KAFKA_OFFSET_TAG

public static final String KAFKA_OFFSET_TAG

See Also:

• Constant Field Values

PARTITION_KEY

protected static final String PARTITION_KEY

Constants copied from

invalid reference

org.apache.camel.component.kafka.KafkaConstants

See Also:

• Constant Field Values

PARTITION

protected static final String PARTITION

See Also:

• Constant Field Values

KEY

protected static final String KEY

See Also:

• Constant Field Values

OVERRIDE_TOPIC

protected static final String OVERRIDE_TOPIC

See Also:

• Constant Field Values

OFFSET

protected static final String OFFSET

See Also:

• Constant Field Values

Constructor Details

KafkaSpanDecorator

public KafkaSpanDecorator()

Method Details

getComponent

public String getComponent()

getComponentClassName

public String getComponentClassName()

getDestination

public String getDestination(org.apache.camel.Exchange exchange,
 org.apache.camel.Endpoint endpoint)

Description copied from class: AbstractMessagingSpanDecorator

This method identifies the destination from the supplied exchange and/or endpoint.

Overrides:

getDestination in class AbstractMessagingSpanDecorator

Parameters:

exchange - The exchange

endpoint - The endpoint

Returns:

The message bus destination

beforeTracingEvent

public void beforeTracingEvent(Span span,
 org.apache.camel.Exchange exchange,
 org.apache.camel.Endpoint endpoint)

Specified by:

beforeTracingEvent in interface SpanDecorator

Overrides:

beforeTracingEvent in class AbstractMessagingSpanDecorator