fix: Delay controller startup to avoid 404 in initial list

Author: Techassi

Cargo.lock

@@ -11,7 +11,7 @@ repository = "https://github.com/stackabletech/kafka-operator"
 
 [workspace.dependencies]
 product-config = { git = "https://github.com/stackabletech/product-config.git", tag = "0.8.0" }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "stackable-operator-0.106.2", features = ["telemetry", "versioned", "webhook"] }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "stackable-operator-0.108.0", features = ["crds", "webhook"] }
 
 anyhow = "1.0"
 built = { version = "0.8", features = ["chrono", "git2"] }

Cargo.nix

@@ -96,6 +96,9 @@ rules:
       {{- if .Values.maintenance.customResourceDefinitions.maintain }}
       - create
       - patch
+      # Required for startup condition
+      - list
+      - watch
       {{- end }}
   - apiGroups:
       - events.k8s.io

Cargo.toml

@@ -19,7 +19,7 @@ use stackable_operator::{
         rbac::v1::RoleBinding,
     },
     kube::{
-        ResourceExt,
+        CustomResourceExt, ResourceExt,
         core::DeserializeGuard,
         runtime::{
             Controller,
@@ -31,7 +31,7 @@ use stackable_operator::{
     logging::controller::report_controller_reconciled,
     shared::yaml::SerializeOptions,
     telemetry::Tracing,
-    utils::signal::SignalWatcher,
+    utils::signal::{self, SignalWatcher},
 };
 
 use crate::{
@@ -209,7 +209,12 @@ async fn main() -> anyhow::Result<()> {
                 )
                 .map(anyhow::Ok);
 
-            futures::try_join!(kafka_controller, eos_checker, webhook_server)?;
+            let delayed_kafka_controller = async {
+                signal::crd_established(&client, v1alpha1::KafkaCluster::crd_name(), None).await?;
+                kafka_controller.await
+            };
+
+            futures::try_join!(delayed_kafka_controller, eos_checker, webhook_server)?;
         }
     };