use strings.EqualFold

Signed-off-by: Calum Murray <cmurray@redhat.com>
knative-extensions · Apr 12, 2024 · 6814585 · 6814585
1 parent f092649
commit 6814585
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 9 deletions.
diff --git a/control-plane/pkg/reconciler/consumer/controller.go b/control-plane/pkg/reconciler/consumer/controller.go
@@ -97,14 +97,9 @@ func NewController(ctx context.Context, watcher configmap.Watcher) *controller.I
 			return nil, false
 		}
 
-		for _, ref := range c.GetOwnerReferences() {
-			if ref.Kind == "ConsumerGroup" {
-				cg, err := r.ConsumerGroupLister.ConsumerGroups(c.GetNamespace()).Get(ref.Name)
-				return cg, err == nil
-			}
-		}
-
-		return nil, false
+		cgRef := c.GetConsumerGroup()
+		cg, err := r.ConsumerGroupLister.ConsumerGroups(c.GetNamespace()).Get(cgRef.Name)
+		return cg, err == nil
 	})
 
 	trustBundleConfigMapInformer.Informer().AddEventHandler(controller.HandleAll(globalResync))

diff --git a/control-plane/pkg/reconciler/consumergroup/controller.go b/control-plane/pkg/reconciler/consumergroup/controller.go
@@ -220,7 +220,7 @@ func ResyncOnStatefulSetChange(ctx context.Context, filteredResync func(f func(i
 				return false
 			}
 			for _, owner := range cg.OwnerReferences {
-				if owner.Kind == kind {
+				if strings.EqualFold(owner.Kind, kind) {
 					return true
 				}
 			}