diff --git a/control-plane/pkg/reconciler/channel/controller.go b/control-plane/pkg/reconciler/channel/controller.go
index e02ef9210a..4adcd87e23 100644
--- a/control-plane/pkg/reconciler/channel/controller.go
+++ b/control-plane/pkg/reconciler/channel/controller.go
@@ -47,10 +47,11 @@ import (
 	podinformer "knative.dev/pkg/client/injection/kube/informers/core/v1/pod"
 	secretinformer "knative.dev/pkg/client/injection/kube/informers/core/v1/secret"
 
+	"knative.dev/eventing/pkg/apis/feature"
+
 	consumergroupclient "knative.dev/eventing-kafka-broker/control-plane/pkg/client/internals/kafka/injection/client"
 	consumergroupinformer "knative.dev/eventing-kafka-broker/control-plane/pkg/client/internals/kafka/injection/informers/eventing/v1alpha1/consumergroup"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/prober"
-	"knative.dev/eventing/pkg/apis/feature"
 
 	"knative.dev/pkg/controller"
 
@@ -123,6 +124,10 @@ func NewController(ctx context.Context, watcher configmap.Watcher, configs *conf
 			}
 		})
 
+	globalResync = func(obj interface{}) {
+		impl.GlobalResync(channelInformer.Informer())
+	}
+
 	kafkaConfigStore := apisconfig.NewStore(ctx, func(name string, value *apisconfig.KafkaFeatureFlags) {
 		reconciler.KafkaFeatureFlags.Reset(value)
 		impl.GlobalResync(channelInformer.Informer())