kafkago

type Message struct {
	kafka.Message
	Ctx context.Context
}

type Reader interface {
	Stats() kafka.ReaderStats
	SetOffsetAt(ctx context.Context, t time.Time) error
	SetOffset(offset int64) error
	Lag() int64
	Offset() int64
	ReadLag(ctx context.Context) (lag int64, err error)
	CommitMessages(ctx context.Context, msgs ...Message) error
	FetchMessage(ctx context.Context) (Message, error)
	ReadMessage(ctx context.Context) (Message, error)
	Close() error
	Config() kafka.ReaderConfig
	WithTracer(trace.Tracer) Reader
}

type Writer interface {
	WriteMessages(ctx context.Context, msgs ...kafka.Message) error
	Close() error
}