Class KafkaActivityEnricher

Enriches the Activity with Kafka specific tags.

Inheritance
object
KafkaActivityEnricher
Inherited Members
Namespace: Silverback.Diagnostics
Assembly: Silverback.Integration.Kafka.dll
Syntax
public class KafkaActivityEnricher : IBrokerActivityEnricher<KafkaConsumerEndpointConfiguration>, IBrokerActivityEnricher<KafkaProducerEndpointConfiguration>, IBrokerActivityEnricher

Constructors

KafkaActivityEnricher()

Enriches the Activity with Kafka specific tags.

Declaration
public KafkaActivityEnricher()

Methods

EnrichInboundActivity(Activity, ConsumerPipelineContext)

Enriches Activities created by the ActivityConsumerBehavior.

Declaration
public void EnrichInboundActivity(Activity activity, ConsumerPipelineContext consumerContext)
Parameters
Type Name Description
Activity activity

The Activity to be enriched.
ConsumerPipelineContext consumerContext

The ConsumerPipelineContext.

EnrichOutboundActivity(Activity, ProducerPipelineContext)

Enriches Activities created by the ActivityProducerBehavior.

Declaration
public void EnrichOutboundActivity(Activity activity, ProducerPipelineContext producerContext)
Parameters
Type Name Description
Activity activity

The Activity to be enriched.
ProducerPipelineContext producerContext

The ProducerPipelineContext.

Implements