kafka

Mar 19, 2021

Changes in this version

type ListenerOption

+ func ListenerReadTimeout(readTimeout time.Duration) ListenerOption

Mar 19, 2021

Changes in this version

type ListenerOption

+ func ListenerAsyncHandle(asyncHandle bool) ListenerOption

Jan 28, 2021

Changes in this version

type ListenerOption

+ func ListenerManualCommit(manualCommit bool) ListenerOption

Jan 28, 2021

Changes in this version

+ type Committer interface

+ Commit func(ctx context.Context) error

+ CommitMessage func(ctx context.Context, msg Message) error

Jan 21, 2021

Changes in this version

+ type NoopErrorHandler struct

+ func NewNoopErrorHandler() *NoopErrorHandler

+ func (eh *NoopErrorHandler) Handle(context.Context, error)

Jan 19, 2021

Changes in this version

+ type Handler interface

+ Handle func(ctx context.Context, msg Message) error

+ type Handlers map[string]Handler

+ type Header interface

+ Key func() string

+ Value func() []byte

+ type Listener struct

+ func NewListener(reader Reader, handlers Handlers, opts ...ListenerOption) (*Listener, error)

+ func (l *Listener) Close() error

+ func (l *Listener) Listen(ctx context.Context) error

+ type ListenerOption func(*Listener)

+ func ListenerErrorHandler(errorHandler transport.ErrorHandler) ListenerOption

+ func ListenerErrorLogger(logger log.Logger) ListenerOption

+ type Message interface

+ Headers func() []Header

+ Key func() []byte

+ Offset func() int64

+ Partition func() int32

+ Timestamp func() time.Time

+ Topic func() string

+ Value func() []byte

+ type NopErrorHandler struct

+ func NewNopErrorHandler() *NopErrorHandler

+ func (neh *NopErrorHandler) Handle(context.Context, error)

+ type Reader interface

+ ReadMessage func(ctx context.Context) (Message, error)