Update Kafka PDB to use live Pods instead of the CR Spec (#770)

Co-authored-by: Toader Sebastian <[email protected]>
banzaicloud · Mar 22, 2022 · d4967e4 · d4967e4
1 parent fbce6a0
commit d4967e4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/resources/kafka/poddisruptionbudget.go b/pkg/resources/kafka/poddisruptionbudget.go
@@ -74,7 +74,7 @@ func (r *Reconciler) computeMinAvailable(log logr.Logger) (intstr.IntOrString, e
 
 	*/
 	// number of brokers in the KafkaCluster
-	brokers := len(r.KafkaCluster.Spec.Brokers)
+	brokers := len(r.KafkaCluster.Status.BrokersState)
 
 	// configured budget in the KafkaCluster
 	disruptionBudget := r.KafkaCluster.Spec.DisruptionBudget.Budget