diff --git a/operator/src/main/java/com/datastax/oss/kaap/controllers/function/FunctionsWorkerResourcesFactory.java b/operator/src/main/java/com/datastax/oss/kaap/controllers/function/FunctionsWorkerResourcesFactory.java index 829484ae..3cabdbaa 100644 --- a/operator/src/main/java/com/datastax/oss/kaap/controllers/function/FunctionsWorkerResourcesFactory.java +++ b/operator/src/main/java/com/datastax/oss/kaap/controllers/function/FunctionsWorkerResourcesFactory.java @@ -299,7 +299,7 @@ public void patchConfigMap() { "pulsarRootDir", "/pulsar", "submittingInsidePod", true, "pulsarServiceUrl", brokerServiceUrl, - "pulsarAdminUrl", "https://%s.%s:6750/" + "pulsarAdminUrl", "https://%s.%s:6751/" .formatted(resourceName, getServiceDnsSuffix()), "percentMemoryPadding", 10) ); diff --git a/operator/src/main/java/com/datastax/oss/kaap/controllers/zookeeper/ZooKeeperResourcesFactory.java b/operator/src/main/java/com/datastax/oss/kaap/controllers/zookeeper/ZooKeeperResourcesFactory.java index bb6a2a69..cbebceab 100644 --- a/operator/src/main/java/com/datastax/oss/kaap/controllers/zookeeper/ZooKeeperResourcesFactory.java +++ b/operator/src/main/java/com/datastax/oss/kaap/controllers/zookeeper/ZooKeeperResourcesFactory.java @@ -61,7 +61,7 @@ public class ZooKeeperResourcesFactory extends BaseResourcesFactory DEFAULT_ENV = List.of("ZOOKEEPER_SERVERS");