Skip to content

Commit a4e80e5

Browse files
committed
wip: use correct suffix
1 parent 02a87d3 commit a4e80e5

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

rust/operator-binary/src/crd/listener.rs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,10 @@ use snafu::{OptionExt, Snafu};
77
use stackable_operator::{kube::ResourceExt, utils::cluster_info::KubernetesClusterInfo};
88
use strum::{EnumDiscriminants, EnumString};
99

10-
use crate::crd::{security::KafkaTlsSecurity, v1alpha1, STACKABLE_LISTENER_BROKER_DIR};
10+
use crate::crd::{
11+
security::KafkaTlsSecurity, v1alpha1, LISTENER_BROKER_VOLUME_NAME,
12+
STACKABLE_LISTENER_BROKER_DIR,
13+
};
1114

1215
const LISTENER_LOCAL_ADDRESS: &str = "0.0.0.0";
1316

@@ -263,8 +266,7 @@ pub fn pod_kcat(
263266
cluster_info: &KubernetesClusterInfo,
264267
) -> Result<String, KafkaListenerError> {
265268
Ok(format!(
266-
// TODO where does this prefix come from? Is it safe to hard-code it?
267-
"$POD_NAME-listener-broker.{namespace}.svc.{cluster_domain}",
269+
"$POD_NAME-{LISTENER_BROKER_VOLUME_NAME}.{namespace}.svc.{cluster_domain}",
268270
namespace = kafka.namespace().context(ObjectHasNoNamespaceSnafu)?,
269271
cluster_domain = cluster_info.cluster_domain
270272
))

0 commit comments

Comments
 (0)