Versions in this module Expand all Collapse all v1 v1.0.0 Jul 2, 2023 Changes in this version + type Reader struct + R *kafka.Reader + func WrapReader(r *kafka.Reader) *Reader + func (r *Reader) ReadMessage(ctx context.Context) (kafka.Message, error) + func (r *Reader) ReadMessageTx(ctx context.Context) (msg kafka.Message, tx *apm.Transaction, err error) + type Writer struct + W *kafka.Writer + func WrapWriter(w *kafka.Writer) *Writer + func (w *Writer) WriteMessages(ctx context.Context, msgs ...kafka.Message) error
Go to main page