Skip to content

Commit 72c71b4

Browse files
committed
wip: provisional fix with pod_kcat instead of pod_fqdn
1 parent f23ff3d commit 72c71b4

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -263,6 +263,7 @@ pub fn pod_kcat(
263263
cluster_info: &KubernetesClusterInfo,
264264
) -> Result<String, KafkaListenerError> {
265265
Ok(format!(
266+
// TODO where does this prefix come from? Is it safe to hard-code it?
266267
"$POD_NAME-listener-broker.{namespace}.svc.{cluster_domain}",
267268
namespace = kafka.namespace().context(ObjectHasNoNamespaceSnafu)?,
268269
cluster_domain = cluster_info.cluster_domain

0 commit comments

Comments
 (0)