diff --git a/control-plane/pkg/reconciler/consumergroup/consumergroup.go b/control-plane/pkg/reconciler/consumergroup/consumergroup.go index 3699342b06..7d27f9aba0 100644 --- a/control-plane/pkg/reconciler/consumergroup/consumergroup.go +++ b/control-plane/pkg/reconciler/consumergroup/consumergroup.go @@ -75,6 +75,7 @@ func (r Reconciler) reconcileConsumers(ctx context.Context, cg *kafkainternals.C for _, pc := range placementConsumers { if pc.Placement == nil { + // There is no placement for pc.Consumers, so they need to be finalized. for _, c := range pc.Consumers { if err := r.finalizeConsumer(ctx, c); err != nil { return cg.MarkReconcileConsumersFailed("FinalizeConsumer", err)