Class KafkaActivityEnricher

Namespace

Silverback.Diagnostics

Assembly

Silverback.Integration.Kafka.dll

Enriches the Activity with Kafka specific tags.

public class KafkaActivityEnricher : IBrokerActivityEnricher<KafkaConsumerEndpointConfiguration>, IBrokerActivityEnricher<KafkaProducerEndpointConfiguration>, IBrokerActivityEnricher

Inheritance

object

KafkaActivityEnricher

Implements

IBrokerActivityEnricher<KafkaConsumerEndpointConfiguration>

IBrokerActivityEnricher<KafkaProducerEndpointConfiguration>

IBrokerActivityEnricher

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

KafkaActivityEnricher()

public KafkaActivityEnricher()

Methods

EnrichInboundActivity(Activity, ConsumerPipelineContext)

Enriches Activities created by the ActivityConsumerBehavior.

public void EnrichInboundActivity(Activity activity, ConsumerPipelineContext consumerContext)

Parameters

activity Activity

The Activity to be enriched.

consumerContext ConsumerPipelineContext

The ConsumerPipelineContext.

EnrichOutboundActivity(Activity, ProducerPipelineContext)

Enriches Activities created by the ActivityProducerBehavior.

public void EnrichOutboundActivity(Activity activity, ProducerPipelineContext producerContext)

Parameters

activity Activity

The Activity to be enriched.

producerContext ProducerPipelineContext

The ProducerPipelineContext.