[bug-fix] - Cluster Status Never Updated (#235)

dvaseekara · Daniel Vaseekaran · web-flow · commit a1123afac423 · 2026-03-03T13:37:55.000-05:00
Co-authored-by: Daniel Vaseekaran &lt;red10447@adobe.com&gt;
diff --git a/controllers/kafkacluster_controller.go b/controllers/kafkacluster_controller.go
@@ -197,10 +197,6 @@ func (r *KafkaClusterReconciler) Reconcile(ctx context.Context, request ctrl.Req
 		if err := k8sutil.UpdateRollingUpgradeState(r.Client, instance, time.Now(), log); err != nil {
 			return requeueWithError(log, err.Error(), err)
 		}
-		// Don't transition to Running state while rolling upgrade is in progress
-		// The state will be updated to Running by the kafka reconciler when the upgrade completes
-		log.Info("Rolling upgrade in progress, keeping current state")
-		return reconciled()
 	}
 
 	if err := k8sutil.UpdateCRStatus(r.Client, instance, v1beta1.KafkaClusterRunning, log); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -197,10 +197,6 @@ func (r *KafkaClusterReconciler) Reconcile(ctx context.Context, request ctrl.Req`
`197`	`197`	`if err := k8sutil.UpdateRollingUpgradeState(r.Client, instance, time.Now(), log); err != nil {`
`198`	`198`	`return requeueWithError(log, err.Error(), err)`
`199`	`199`	`}`
`200`		`- // Don't transition to Running state while rolling upgrade is in progress`
`201`		`- // The state will be updated to Running by the kafka reconciler when the upgrade completes`
`202`		`- log.Info("Rolling upgrade in progress, keeping current state")`
`203`		`- return reconciled()`
`204`	`200`	`}`
`205`	`201`
`206`	`202`	`if err := k8sutil.UpdateCRStatus(r.Client, instance, v1beta1.KafkaClusterRunning, log); err != nil {`