public class KafkaSegmentDecorator extends AbstractMessagingSegmentDecorator
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 |
---|
KafkaSegmentDecorator() |
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) |
void |
pre(com.amazonaws.xray.entities.Entity segment,
org.apache.camel.Exchange exchange,
org.apache.camel.Endpoint endpoint)
This method adds appropriate details (tags/logs) to the supplied segment based on the pre processing of the
exchange.
|
getMessageId, getOperationName
newSegment, 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()
SegmentDecorator
public String getDestination(org.apache.camel.Exchange exchange, org.apache.camel.Endpoint endpoint)
getDestination
in class AbstractMessagingSegmentDecorator
public void pre(com.amazonaws.xray.entities.Entity segment, org.apache.camel.Exchange exchange, org.apache.camel.Endpoint endpoint)
SegmentDecorator
pre
in interface SegmentDecorator
pre
in class AbstractMessagingSegmentDecorator
segment
- The segmentexchange
- The exchangeendpoint
- The endpointApache Camel