Versions in this module Expand all Collapse all v0 v0.0.1 May 25, 2022 Changes in this version + var Default = New() + var DefaultOptions = Options + var ErrProxyAllreadySettedCallback = errors.New("cannot reset callback") + var ErrProxyAllreadySettedClient = errors.New("cannot reset consumer") + var Logger *log.Log + func WithAutoOffsetReset(strategy string) optparams.Option[Options] + func WithComsumerSetting(key string, value any) optparams.Option[Options] + func WithGroupID(groupID string) optparams.Option[Options] + func WithIsolationLevel(strategy string) optparams.Option[Options] + func WithParallelCallback() optparams.Option[Options] + func WithUUID4GroupID(namespace ...string) optparams.Option[Options] + type Callback func(cli *kafka.Consumer) error + type ConsumerProxy struct + Opt Options + func New() *ConsumerProxy + func (proxy *ConsumerProxy) Init(endpoints string, opts ...optparams.Option[Options]) error + func (proxy *ConsumerProxy) IsOk() bool + func (proxy *ConsumerProxy) OnError(cb OnErrorCallback) error + func (proxy *ConsumerProxy) OnMessage(cb OnMsgCallback) error + func (proxy *ConsumerProxy) Regist(cb ...Callback) error + func (proxy *ConsumerProxy) SetConnect(cli *kafka.Consumer) error + func (proxy *ConsumerProxy) Watch() func() + type OnErrorCallback func(err kafka.Error) + type OnMsgCallback func(evt *kafka.Message) + type Options struct + ParallelCallback bool
Go to main page