Set GetKafkaClient

Signed-off-by: Pierangelo Di Pilato <pierdipi@redhat.com>
knative-extensions · Sep 19, 2024 · 5db6305 · 5db6305
1 parent 3b38863
commit 5db6305
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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
 	}