ExtractSpanContext retrieves the SpanContext from a kafka.Message.

NewReader calls kafka.NewReader and wraps the resulting Consumer.

NewWriter calls kafka.NewWriter and wraps the resulting Producer.

WrapReader wraps a kafka.Reader so that any consumed events are traced.

WrapWriter wraps a kafka.Writer so requests are traced.

WithAnalytics enables Trace Analytics for all started spans.

WithAnalyticsRate sets the sampling rate for Trace Analytics events correlated to started spans.

WithDataStreams enables the Data Streams monitoring product features: https://www.datadoghq.com/product/data-streams-monitoring/.

WithServiceName sets the config service name to serviceName.

A Reader wraps a kafka.Reader.

Writer wraps a kafka.Writer with tracing config data.

An Option customizes the config.