diff --git a/helm-chart-sources/pulsar/templates/function/function-configmap.yaml b/helm-chart-sources/pulsar/templates/function/function-configmap.yaml index 1f72f80a..a19b3699 100644 --- a/helm-chart-sources/pulsar/templates/function/function-configmap.yaml +++ b/helm-chart-sources/pulsar/templates/function/function-configmap.yaml @@ -164,9 +164,13 @@ data: # setting this to true is let function worker to submit functions to the same k8s cluster as function worker # is running. setting this to false if your function worker is not running as a k8 pod. submittingInsidePod: true + {{- if and .Values.enableTls .Values.tls.function.enableTlsWithBroker }} # setting the pulsar service url that pulsar function should use to connect to pulsar # if it is not set, it will use the pulsar service url configured in worker service + pulsarServiceUrl: "pulsar+ssl://{{ template "pulsar.fullname" . }}-{{ .Values.brokerSts.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:6651/" + {{- else }} pulsarServiceUrl: "pulsar://{{ template "pulsar.fullname" . }}-{{ .Values.broker.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:6650/" + {{- end }} # setting the pulsar admin url that pulsar function should use to connect to pulsar # if it is not set, it will use the pulsar admin url configured in worker service pulsarAdminUrl: "http://{{ template "pulsar.fullname" . }}-{{ .Values.function.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:6750/" diff --git a/helm-chart-sources/pulsar/templates/proxy/proxy-ws-configmap.yaml b/helm-chart-sources/pulsar/templates/proxy/proxy-ws-configmap.yaml index 19b0689f..94672c94 100644 --- a/helm-chart-sources/pulsar/templates/proxy/proxy-ws-configmap.yaml +++ b/helm-chart-sources/pulsar/templates/proxy/proxy-ws-configmap.yaml @@ -30,11 +30,18 @@ metadata: cluster: {{ template "pulsar.fullname" . }} data: {{- if .Values.proxy.disableZookeeperDiscovery }} + {{- if .Values.proxy.useStsBrokersForDiscovery }} + brokerServiceURL: "pulsar://{{ template "pulsar.fullname" . }}-{{ .Values.brokerSts.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:6650" + brokerServiceURLTLS: "pulsar+ssl://{{ template "pulsar.fullname" . }}-{{ .Values.brokerSts.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:6651" + brokerWebServiceURL: "http://{{ template "pulsar.fullname" . }}-{{ .Values.brokerSts.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:8080" + brokerWebServiceURLTLS: "https://{{ template "pulsar.fullname" . }}-{{ .Values.brokerSts.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:8443" + {{- else }} brokerServiceUrl: "pulsar://{{ template "pulsar.fullname" . }}-{{ .Values.broker.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:6650" brokerServiceUrlTls: "pulsar+ssl://{{ template "pulsar.fullname" . }}-{{ .Values.broker.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:6651" serviceUrl: "http://{{ template "pulsar.fullname" . }}-{{ .Values.broker.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:8080" serviceUrlTls: "https://{{ template "pulsar.fullname" . }}-{{ .Values.broker.component }}.{{ template "pulsar.serviceDnsSuffix" . }}:8443" {{- end }} + {{- end }} zookeeperServers: {{- if and .Values.enableTls .Values.tls.zookeeper.enabled }} "{{ template "pulsar.fullname" . }}-{{ .Values.zookeeper.component }}-ca.{{ template "pulsar.serviceDnsSuffix" . }}:2281" diff --git a/helm-chart-sources/pulsar/values.yaml b/helm-chart-sources/pulsar/values.yaml index f7eb94c4..86988428 100644 --- a/helm-chart-sources/pulsar/values.yaml +++ b/helm-chart-sources/pulsar/values.yaml @@ -1267,7 +1267,8 @@ proxy: component: proxy replicaCount: 3 disableZookeeperDiscovery: true - useStsBrokersForDiscover: false + # use "brokersts" instead of "broker" to identify the broker k8s component + useStsBrokersForDiscovery: false updateStrategy: type: RollingUpdate rollingUpdate: