[KAFKA-13688] Incorrect metrics in KafkaController for replicasToDeleteCount and ineligibleReplicasToDeleteCount

• Type: Bug
• Status: Patch Available
• Priority: Major
• Resolution: Unresolved
• Component/s: controller
• Assignee: Unassigned
• Reporter: Crispin Bernier
• Created: 22/Feb/22 23:22
• Updated: 14/Jul/23 13:39

Description

    replicasToDeleteCount = if (!isActive) 0 else controllerContext.topicsToBeDeleted.map { topic =>      // For each enqueued topic, count the number of replicas that are not yet deleted      controllerContext.replicasForTopic(topic).count { replica =>        controllerContext.replicaState(replica) != ReplicaDeletionSuccessful      }    }.sum

    ineligibleReplicasToDeleteCount = if (!isActive) 0 else controllerContext.topicsToBeDeleted.map { topic =>      // For each enqueued topic, count the number of replicas that are ineligible      controllerContext.replicasForTopic(topic).count { replica =>        controllerContext.replicaState(replica) == ReplicaDeletionIneligible      }    }.sum 

Duplicate replica counts will get ignored in the total sum when the code above converts to a set.

Issue Links

• links to: GitHub Pull Request #11799