diff --git a/knative-operator/pkg/controller/knativekafka/knativekafka_controller.go b/knative-operator/pkg/controller/knativekafka/knativekafka_controller.go index 7f06625314..f31a51480a 100644 --- a/knative-operator/pkg/controller/knativekafka/knativekafka_controller.go +++ b/knative-operator/pkg/controller/knativekafka/knativekafka_controller.go @@ -645,7 +645,7 @@ func configureEventingKafka(spec serverlessoperatorv1alpha1.KnativeKafkaSpec) mf if u.GetKind() == "Deployment" && u.GetName() == "kafka-controller" { var disabledKafkaControllers = common.StringMap{ - brokerController: "broker-controller,trigger-controller,namespaced-broker-controller,namespaced-trigger-controller", + brokerController: "broker-controller,trigger-controller", sinkController: "sink-controller", sourceController: "source-controller", channelController: "channel-controller", diff --git a/knative-operator/pkg/controller/knativekafka/knativekafka_controller_test.go b/knative-operator/pkg/controller/knativekafka/knativekafka_controller_test.go index 4b7abe2532..4407c570cb 100644 --- a/knative-operator/pkg/controller/knativekafka/knativekafka_controller_test.go +++ b/knative-operator/pkg/controller/knativekafka/knativekafka_controller_test.go @@ -607,7 +607,7 @@ func TestDisabledControllers(t *testing.T) { Enabled: true, }, }, - expectedDisabledControllers: []string{"broker-controller", "trigger-controller", "namespaced-broker-controller", "namespaced-trigger-controller", "source-controller"}, + expectedDisabledControllers: []string{"broker-controller", "trigger-controller", "source-controller"}, }, { name: "broker and sink", knativeKafka: v1alpha1.KnativeKafkaSpec{ @@ -629,7 +629,7 @@ func TestDisabledControllers(t *testing.T) { Enabled: false, }, }, - expectedDisabledControllers: []string{"broker-controller", "trigger-controller", "namespaced-broker-controller", "namespaced-trigger-controller", "sink-controller", "source-controller"}, + expectedDisabledControllers: []string{"broker-controller", "trigger-controller", "sink-controller", "source-controller"}, }} for _, test := range tests {