Use Kafka Status instead of Spec for Kafka PDB

banzaicloud · Mar 18, 2022 · 7724253 · 7724253
1 parent 9488639
commit 7724253
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