Versions in this module Expand all Collapse all v0 v0.1.0 May 2, 2021 Changes in this version + func NewConfig(topic string, brokers []string, callbackFunc ExecuteFunc) *config + type ExecuteFunc func(record *data.Record) error + type Watcher struct + func New(ctx context.Context, cfg *config) (*Watcher, error) + func (c Watcher) SetLogger(l log.Logger) + func (w *Watcher) Close() + func (w *Watcher) Subscribe(synced chan<- bool)