Versions in this module Expand all Collapse all v1 v1.2.0 Dec 12, 2019 Changes in this version + type Handler struct + func NewHandler(events <-chan kafka.Event, wg *sync.WaitGroup, msgStore store.MsgStore, ...) *Handler + func (h *Handler) Handle() + type Option func(*Producer) + func Register(cb callback.Callback) Option + type Producer struct + func New(prodCfg config.Producer, mc msgCreator, encoder serde.Encoder, opts ...Option) (*Producer, error) + func (p *Producer) Register(cb callback.Callback) + func (p Producer) Close() error + func (p Producer) Poll(ctx context.Context) + func (p Producer) ProduceWorker(ctx context.Context) + func (p Producer) Run(ctx context.Context)