Versions in this module Expand all Collapse all v0 v0.14.0 May 8, 2020 Changes in this version + const ReconcilerName + func NewController(logger *zap.Logger, dispatcher *dispatcher.Dispatcher, ...) *controller.Impl + type Reconciler struct + KafkaClientSet versioned.Interface + Logger *zap.Logger + Recorder record.EventRecorder + func (r Reconciler) Reconcile(ctx context.Context, key string) error