fix: unit tests expect correct cg status

Signed-off-by: Calum Murray <cmurray@redhat.com>
knative-extensions · Feb 2, 2024 · 71de444 · 71de444
1 parent f14b958
commit 71de444
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/control-plane/pkg/reconciler/testing/objects_consumergroup.go b/control-plane/pkg/reconciler/testing/objects_consumergroup.go
@@ -23,6 +23,7 @@ import (
 
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/labels"
 	"k8s.io/utils/pointer"
 	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
@@ -105,6 +106,9 @@ func NewConsumerGroup(opts ...ConsumerGroupOption) *kafkainternals.ConsumerGroup
 				},
 			},
 		},
+		Status: kafkainternals.ConsumerGroupStatus{
+			Selector: labels.SelectorFromSet(ConsumerLabels).String(),
+		},
 	}
 
 	for _, opt := range opts {