NewConsumer calls kafka.NewConsumer and wraps the resulting Consumer.

NewMessageCarrier creates a new MessageCarrier.

NewProducer calls kafka.NewProducer and wraps the resulting Producer.

WithAnalytics enables Trace Analytics for all started spans.

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

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

WithContext sets the config context to ctx.

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

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

WithServiceName sets the config service name to serviceName.

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

WrapProducer wraps a kafka.Producer so requests are traced.

A Consumer wraps a kafka.Consumer.

A MessageCarrier injects and extracts traces from a sarama.ProducerMessage.

A Producer wraps a kafka.Producer.

An Option customizes the config.