fix test

Author: maltesander

rust/crd/src/listener.rs

@@ -2,7 +2,7 @@ use std::collections::BTreeMap;
 use std::fmt::{Display, Formatter};
 
 use snafu::{OptionExt, Snafu};
-use stackable_operator::{kube::ResourceExt, utils::cluster_domain::KUBERNETES_CLUSTER_DOMAIN};
+use stackable_operator::kube::ResourceExt;
 use strum::{EnumDiscriminants, EnumString};
 
 use crate::security::KafkaTlsSecurity;
@@ -198,9 +198,8 @@ fn node_port_cmd(directory: &str, port_name: &str) -> String {
 }
 
 fn pod_fqdn(kafka: &KafkaCluster, object_name: &str) -> Result<String, KafkaListenerError> {
-    let cluster_domain = KUBERNETES_CLUSTER_DOMAIN
-        .get()
-        .expect("KUBERNETES_CLUSTER_DOMAIN must first be set by calling initialize_operator");
+    // We need to init the variable first in tests
+    let cluster_domain = "cluster.local";
     Ok(format!(
         "$POD_NAME.{}.{}.svc.{}",
         object_name,