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) (k *Kfk, err error) + func (k *Kfk) Close() (err error) + func (k *Kfk) Flush() (err error) + func (k *Kfk) Name() string + func (k *Kfk) SetLogger(l *common.Logger) + func (k *Kfk) Start() + func (k *Kfk) Stats() string + func (k *Kfk) Status() error + func (k *Kfk) Subscribe(s sink.Sink) + func (k *Kfk) Type() string
Go to main page