feat: support kop proxy in chart (#1190)

* feat: support kop proxy in chart Signed-off-by: ericsyh <[email protected]> * fix lint Signed-off-by: ericsyh <[email protected]> --------- Signed-off-by: ericsyh <[email protected]> (cherry picked from commit da726e7)
streamnative · Nov 22, 2024 · 8d8f3da · 8d8f3da
1 parent 34b7f77
commit 8d8f3da
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 0 deletions.
diff --git a/charts/sn-platform-slim/templates/proxy/proxy-cluster.yaml b/charts/sn-platform-slim/templates/proxy/proxy-cluster.yaml
@@ -140,6 +140,11 @@ spec:
     {{- if .Values.pulsar_metadata.clusterName }}
     clusterName: {{ .Values.pulsar_metadata.clusterName }}
     {{- end }}
+    {{- if .Values.proxy.kopProxy.enabled }}
+    kopProxy:
+      enabled: {{ .Values.proxy.kopProxy.enabled }}
+      kafkaAdvertisedListener: {{ .Values.proxy.kopProxy.kafkaAdvertisedListener }}
+    {{- end }}
     usePodIPAsAdvertisedAddress: {{ .Values.broker.usePodIPAsAdvertisedAddress | default "false" }}
     tls:
       enabled: {{ and (.Values.tls.enabled) (.Values.tls.proxy.enabled) }}

diff --git a/charts/sn-platform-slim/values.yaml b/charts/sn-platform-slim/values.yaml
@@ -1503,6 +1503,11 @@ proxy:
     # limits:
     #   memory: "512Mi"
     #   cpu: "0.8"
+  # Kafka Proxy supports forward the kafka client request to Pulsar Broker, make sure you enable the kop on the Broker component.
+  kopProxy:
+    enabled: false
+    # Specifies the listeners for Kafka clients. In Kubernetes environments, you should configure the external Proxy LoadBalancer type service address or NodePort type service address for this field.
+    kafkaAdvertisedListener:
   # extra environment variable to define for the containers
   extraEnv: []
   # extra secrets to mount for the pods

diff --git a/charts/sn-platform/templates/proxy/proxy-cluster.yaml b/charts/sn-platform/templates/proxy/proxy-cluster.yaml
@@ -140,6 +140,11 @@ spec:
     {{- if .Values.pulsar_metadata.clusterName }}
     clusterName: {{ .Values.pulsar_metadata.clusterName }}
     {{- end }}
+    {{- if .Values.proxy.kopProxy.enabled }}
+    kopProxy:
+      enabled: {{ .Values.proxy.kopProxy.enabled }}
+      kafkaAdvertisedListener: {{ .Values.proxy.kopProxy.kafkaAdvertisedListener }}
+    {{- end }}
     usePodIPAsAdvertisedAddress: {{ .Values.broker.usePodIPAsAdvertisedAddress | default "false" }}
     tls:
       enabled: {{ and (.Values.tls.enabled) (.Values.tls.proxy.enabled) }}

diff --git a/charts/sn-platform/values.yaml b/charts/sn-platform/values.yaml
@@ -1579,6 +1579,11 @@ proxy:
     # limits:
     #   memory: "512Mi"
     #   cpu: "0.8"
+  # Kafka Proxy supports forward the kafka client request to Pulsar Broker, make sure you enable the kop on the Broker component.
+  kopProxy:
+    enabled: false
+    # Specifies the listeners for Kafka clients. In Kubernetes environments, you should configure the external Proxy LoadBalancer type service address or NodePort type service address for this field.
+    kafkaAdvertisedListener:
   # extra environment variable to define for the containers
   extraEnv: []
   # extra secrets to mount for the pods