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<KafkaConsumerEndpoint>, IBrokerActivityEnricher<KafkaProducerEndpoint>, IBrokerActivityEnricher

Methods

| Improve this doc View source

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.
| Improve this doc View source

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