NewConsumer calls kafka.NewConsumer and wraps the resulting Consumer.

NewMessageCarrier creates a new MessageCarrier.

NewProducer calls kafka.NewProducer and wraps the resulting Producer.

WithConfig extracts the config information for the client to be tagged.

WithCustomTag will cause the given tagFn to be evaluated after executing a query and attach the result to the span tagged by the key.

WrapConsumer wraps a kafka.Consumer so that any consumed events are traced.

WrapProducer wraps a kafka.Producer 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.

WithContext sets the config context to ctx.

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 Consumer wraps a kafka.Consumer.

A Producer wraps a kafka.Producer.

A MessageCarrier injects and extracts traces from a kafka.Message.

An Option customizes the config.