Versions in this module Expand all Collapse all v1 v1.0.2 May 10, 2023 Changes in this version + func ExtractSpanContext(msg kafka.Message) (ddtrace.SpanContext, error) + type Option func(cfg *config) + func WithAnalytics(on bool) Option + func WithAnalyticsRate(rate float64) Option + func WithServiceName(serviceName string) Option + type Reader struct + func NewReader(conf kafka.ReaderConfig, opts ...Option) *Reader + func WrapReader(c *kafka.Reader, opts ...Option) *Reader + func (r *Reader) Close() error + func (r *Reader) FetchMessage(ctx context.Context) (kafka.Message, error) + func (r *Reader) ReadMessage(ctx context.Context) (kafka.Message, error) + type Writer struct + func NewWriter(conf kafka.WriterConfig, opts ...Option) *Writer + func WrapWriter(w *kafka.Writer, opts ...Option) *Writer + func (w *Writer) WriteMessages(ctx context.Context, msgs ...kafka.Message) error
Go to main page