diff --git a/control-plane/pkg/reconciler/channel/controller.go b/control-plane/pkg/reconciler/channel/controller.go index 7243204565..4afcb78a53 100644 --- a/control-plane/pkg/reconciler/channel/controller.go +++ b/control-plane/pkg/reconciler/channel/controller.go @@ -85,8 +85,10 @@ func NewController(ctx context.Context, watcher configmap.Watcher, configs *conf clientPool := clientpool.Get(ctx) if clientPool == nil { + reconciler.GetKafkaClient = clientpool.DisabledGetClient reconciler.GetKafkaClusterAdmin = clientpool.DisabledGetKafkaClusterAdminFunc } else { + reconciler.GetKafkaClient = clientPool.GetClient reconciler.GetKafkaClusterAdmin = clientPool.GetClusterAdmin }