Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://farfetch.github.io/kafkaflow/docs/guides/open-telemetry below:

OpenTelemetry instrumentation | KafkaFlow

In this section, we will explore how to enable OpenTelemetry instrumentation when using KafkaFlow.

KafkaFlow includes support for Traces and Baggage signals using OpenTelemetry instrumentation.

tip

You can find a sample on how to enable OpenTelemetry here.

Add the package KafkaFlow.OpenTelemetry to the project and add the extension method AddOpenTelemetryInstrumentation in your configuration:

services.AddKafka(
    kafka => kafka
        .AddCluster(...)
        .AddOpenTelemetryInstrumentation()
);

Once you have your .NET application instrumentation configured (see here), the KafkaFlow activity can be captured by adding the source KafkaFlowInstrumentation.ActivitySourceName in the tracer provider builder, e.g.:

 using var tracerProvider = Sdk.CreateTracerProviderBuilder()
     .AddSource(KafkaFlowInstrumentation.ActivitySourceName)
     ...

The instrumentation can be configured to change the default behavior by using KafkaFlowInstrumentationOptions.

This option can be used to enrich the Activity with additional information from IMessageContext object. It defines separate methods for producer and consumer enrich:

services.AddKafka(
    kafka => kafka
        .AddCluster(...)
        .AddOpenTelemetryInstrumentation(options =>
        {
            options.EnrichProducer = (activity, messageContext) =>
            {
                activity.SetTag("messaging.destination.producername", "KafkaFlowOtel");
            };

            options.EnrichConsumer = (activity, messageContext) =>
            {
                activity.SetTag("messaging.destination.group.id", messageContext.ConsumerContext.GroupId);
            };
        })
);

When using .NET automatic instrumentation, the KafkaFlow activity can be captured by including the ActivitySource name KafkaFlow.OpenTelemetry as a parameter to the variable OTEL_DOTNET_AUTO_TRACES_ADDITIONAL_SOURCES.

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.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4