In this section, we will explore how to enable OpenTelemetry instrumentation when using KafkaFlow.
You can find a sample on how to enable OpenTelemetry here.
Including OpenTelemetry instrumentation in your code
kafka => kafka
Once you have your .NET application instrumentation configured (see here), you just need to subscribe to the source
KafkaFlow.OpenTelemetry that is accessible through a constant at
Using .NET Automatic Instrumentation
When using .NET automatic instrumentation, the KafkaFlow activity can be captured by including the ActivitySource name
KafkaFlow.OpenTelemetry as a parameter to the variable
KafkaFlow uses Propagation, the mechanism that moves context information data between services and processes. When a message is produced using a KafkaFlow producer and consumed by a KafkaFlow consumer, the context will automatically be propagated.