Update ObservedGeneration

OwenCorrigan76 · OwenCorrigan76 · commit 1c73e148b217 · 2025-10-17T16:53:13.000+01:00
Signed-off-by: OwenCorrigan76 &lt;owencorrigan76@gmail.com&gt;
diff --git a/operator/src/main/java/io/strimzi/kafka/access/KafkaAccessReconciler.java b/operator/src/main/java/io/strimzi/kafka/access/KafkaAccessReconciler.java
@@ -94,7 +94,7 @@ public UpdateControl<KafkaAccess> reconcile(final KafkaAccess kafkaAccess, final
 
         kafkaAccessStatus.setBinding(new BindingStatus(secretName));
         kafkaAccessStatus.setReadyCondition(true, "Ready", "Ready");
-
+        kafkaAccessStatus.setObservedGeneration(kafkaAccess.getMetadata().getGeneration());
         return UpdateControl.patchStatus(kafkaAccess);
     }
 
@@ -202,6 +202,7 @@ public ErrorStatusUpdateControl<KafkaAccess> updateErrorStatus(KafkaAccess kafka
             reason = "InvalidUserKind";
         }
         status.setReadyCondition(false, e.getMessage(), reason);
+        status.setObservedGeneration(kafkaAccess.getMetadata().getGeneration());
 
         return ErrorStatusUpdateControl.patchStatus(kafkaAccess);
     }

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ public UpdateControl<KafkaAccess> reconcile(final KafkaAccess kafkaAccess, final`
`94`	`94`
`95`	`95`	`kafkaAccessStatus.setBinding(new BindingStatus(secretName));`
`96`	`96`	`kafkaAccessStatus.setReadyCondition(true, "Ready", "Ready");`
`97`		`-`
	`97`	`+ kafkaAccessStatus.setObservedGeneration(kafkaAccess.getMetadata().getGeneration());`
`98`	`98`	`return UpdateControl.patchStatus(kafkaAccess);`
`99`	`99`	`}`
`100`	`100`
`@@ -202,6 +202,7 @@ public ErrorStatusUpdateControl<KafkaAccess> updateErrorStatus(KafkaAccess kafka`
`202`	`202`	`reason = "InvalidUserKind";`
`203`	`203`	`}`
`204`	`204`	`status.setReadyCondition(false, e.getMessage(), reason);`
	`205`	`+ status.setObservedGeneration(kafkaAccess.getMetadata().getGeneration());`
`205`	`206`
`206`	`207`	`return ErrorStatusUpdateControl.patchStatus(kafkaAccess);`
`207`	`208`	`}`