Rename consumersByPlacement -> placementConsumers

Signed-off-by: Pierangelo Di Pilato <pierdipi@redhat.com>
knative-extensions · Jan 10, 2022 · 6f5c949 · 6f5c949
1 parent 628aafc
commit 6f5c949
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/control-plane/pkg/reconciler/consumergroup/consumergroup.go b/control-plane/pkg/reconciler/consumergroup/consumergroup.go
@@ -71,9 +71,9 @@ func (r Reconciler) reconcileConsumers(ctx context.Context, cg *kafkainternals.C
 		return cg.MarkReconcileConsumersFailed("ListConsumers", err)
 	}
 
-	consumersByPlacement := r.joinConsumersByPlacement(cg.Status.Placements, existingConsumers)
+	placementConsumers := r.joinConsumersByPlacement(cg.Status.Placements, existingConsumers)
 
-	for _, pc := range consumersByPlacement {
+	for _, pc := range placementConsumers {
 		if pc.Placement == nil {
 			for _, c := range pc.Consumers {
 				if err := r.finalizeConsumer(ctx, c); err != nil {