Fixed status updated only when Kafka instance ready with no updating (#…

…472) * Fixed status updated only when Kafka instance ready with no updating * Reviewed comments
bf2fc6cc711aee1a0c2a · Aug 9, 2021 · 13133bc · 13133bc
1 parent e94d1b2
commit 13133bc
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/operator/src/main/java/org/bf2/operator/controllers/ManagedKafkaController.java b/operator/src/main/java/org/bf2/operator/controllers/ManagedKafkaController.java
@@ -16,6 +16,7 @@
 import org.bf2.operator.resources.v1alpha1.ManagedKafka;
 import org.bf2.operator.resources.v1alpha1.ManagedKafkaCapacityBuilder;
 import org.bf2.operator.resources.v1alpha1.ManagedKafkaCondition;
+import org.bf2.operator.resources.v1alpha1.ManagedKafkaCondition.Reason;
 import org.bf2.operator.resources.v1alpha1.ManagedKafkaCondition.Status;
 import org.bf2.operator.resources.v1alpha1.ManagedKafkaStatus;
 import org.bf2.operator.resources.v1alpha1.ManagedKafkaStatusBuilder;
@@ -132,7 +133,11 @@ private void updateManagedKafkaStatus(ManagedKafka managedKafka) {
 
         if (Status.True.equals(readiness.getStatus())) {
             status.setCapacity(new ManagedKafkaCapacityBuilder(managedKafka.getSpec().getCapacity()).build());
-            status.setVersions(new VersionsBuilder(managedKafka.getSpec().getVersions()).build());
+            if (!Reason.StrimziUpdating.equals(readiness.getReason())) {
+                status.setVersions(new VersionsBuilder(managedKafka.getSpec().getVersions()).build());
+            } else {
+                // just keep the current version
+            }
             status.setAdminServerURI(kafkaInstance.getAdminServer().uri(managedKafka));
         }
     }