From 6f5c9498480fdad77c85587320292f5735e11fed Mon Sep 17 00:00:00 2001 From: Pierangelo Di Pilato Date: Fri, 7 Jan 2022 09:53:13 +0100 Subject: [PATCH] Rename consumersByPlacement -> placementConsumers Signed-off-by: Pierangelo Di Pilato --- control-plane/pkg/reconciler/consumergroup/consumergroup.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/control-plane/pkg/reconciler/consumergroup/consumergroup.go b/control-plane/pkg/reconciler/consumergroup/consumergroup.go index fe246dae71..33c0f734b4 100644 --- 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 {