Versions in this module Expand all Collapse all v1 v1.3.0 Jan 28, 2022 Changes in this version + type Kfk struct + func New(name string, v *viper.Viper) (s *Kfk, err error) + func (k *Kfk) Close() (err error) + func (k *Kfk) Name() string + func (k *Kfk) ProcessEventsBatch(events []event.Event) (err error) + func (k *Kfk) SetLogger(l *common.Logger) + func (k *Kfk) Stats() string + func (k *Kfk) Status() error + func (k *Kfk) Type() string