Skip to content

Commit

Permalink
Add comment on why pc.Placement might be nil
Browse files Browse the repository at this point in the history
Signed-off-by: Pierangelo Di Pilato <pierdipi@redhat.com>
  • Loading branch information
pierDipi committed Jan 10, 2022
1 parent a17ec05 commit 59cbd86
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 59cbd86

Please sign in to comment.