kafka

Apr 19, 2024

Changes in this version

type Option

+ func WithDataStreams() Option

Jul 12, 2022

Changes in this version

type Reader

+ func (r *Reader) FetchMessage(ctx context.Context) (kafka.Message, error)

Mar 11, 2022

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) 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