Rename brokerHost to brokerHosts for Kafka connector

The newest version of the Kafka connector will support multiple bootstrap servers as a comma-separated list via the brokerHosts variable, this is a breaking change from previously being brokerHost, and only supporting a single host. Signed-off-by: Alex Ellis (OpenFaaS Ltd) <[email protected]>
openfaas · Sep 19, 2023 · d72d6a5 · d72d6a5
1 parent dcab656
commit d72d6a5
Show file tree

Hide file tree

Showing 7 changed files with 35 additions and 25 deletions.
diff --git a/chart/kafka-connector/templates/deployment.yml b/chart/kafka-connector/templates/deployment.yml
@@ -105,8 +105,8 @@ spec:
             - name: secret_mount_path
               value: "/var/secrets"
             {{- end }}
-            - name: broker_host
-              value: {{ .Values.brokerHost | quote }}
+            - name: broker_hosts
+              value: {{ .Values.brokerHosts | quote }}
             {{- if .Values.upstreamTimeout }}
             - name: upstream_timeout
               value: {{ .Values.upstreamTimeout | quote }}

diff --git a/chart/kafka-connector/values.yaml b/chart/kafka-connector/values.yaml
@@ -1,15 +1,27 @@
-# The Kafka connector is an OpenFaaS Pro feature
-#
-# Purchase a license at https://openfaas.com/support/
+# This component is licensed for OpenFaaS Standard/Enterprise customers only.
+# Purchase or obtain a trial license at https://openfaas.com/pricing/
 
 # You will need to create a license named "openfaas-license" - see the
 # chart README for detailed instructions.
 
+
+# Set either a single topic, or multiple with a comma separating each
+# topics: payment.requested
+# topics: "payment.requested,customer.created,invoice.generated"
+topics: faas-request
+
+# The address of the Kafka broker, if multiple are available, include
+# them as a comma separated list i.e. "kafka-1:9092,kafka-2:9092,kafka-3:9092"
+brokerHosts: kf-kafka:9092
+
 image: ghcr.io/openfaasltd/kafka-connector:0.7.3
 
 # Output detailed logs from the consumer group's lifecycle
 sessionLogging: true
 
+# The number of replicas of the connector should usually match the size of the
+# partition exactly. So for a topic with 6 partitions, set the replicas to 6.
+# This number must not be higher, but can be lower, to save on resources.
 replicas: 1
 
 # Max timeout for a function
@@ -21,14 +33,6 @@ rebuildInterval: 30s
 # Use with slow consumers or long running functions
 asyncInvocation: false
 
-# Set either a single topic, or multiple with a comma separating each
-# topics: payment.requested
-# topics: payment.requested,customer.created,invoice.generated
-topics: faas-request
-
-# Your Kafka broker
-brokerHost: kf-kafka:9092
-
 # 1MB = 1024 bytes * 1024
 maxBytes: "1048576"
 
@@ -85,8 +89,8 @@ resources:
   # limits:
   #   memory: "256Mi"
 
-# Encryption
-tls: false
+# Use TLS Encryption, this is usually set to true.
+tls: true
 
 # Authentication
 

diff --git a/chart/postgres-connector/values.yaml b/chart/postgres-connector/values.yaml
@@ -1,6 +1,5 @@
-# The Postgres connector is an OpenFaaS Pro feature
-#
-# Purchase a license at https://openfaas.com/support/
+# This component is licensed for OpenFaaS Standard/Enterprise customers only.
+# Purchase or obtain a trial license at https://openfaas.com/pricing/
 
 # You will need to create a license named "openfaas-license" - see the
 # chart README for detailed instructions.

diff --git a/chart/pro-builder/values.yaml b/chart/pro-builder/values.yaml
@@ -1,4 +1,7 @@
-# You will need to create a license named "openfaas-license" - see the 
+# This component is licensed for OpenFaaS Standard/Enterprise customers only.
+# Purchase or obtain a trial license at https://openfaas.com/pricing/
+
+# You will need to create a license named "openfaas-license" - see the
 # chart README for detailed instructions.
 
 # image is for the pro-builder API

diff --git a/chart/queue-worker/values.yaml b/chart/queue-worker/values.yaml
@@ -1,3 +1,9 @@
+# This component is licensed for OpenFaaS Standard/Enterprise customers only.
+# Purchase or obtain a trial license at https://openfaas.com/pricing/
+
+# You will need to create a license named "openfaas-license" - see the
+# chart README for detailed instructions.
+
 image: ghcr.io/openfaasltd/jetstream-queue-worker:0.3.13
 
 replicas: 1

diff --git a/chart/sns-connector/values.yaml b/chart/sns-connector/values.yaml
@@ -1,6 +1,5 @@
-# The Kafka connector is an OpenFaaS Pro feature
-#
-# Purchase a license at https://openfaas.com/support/
+# This component is licensed for OpenFaaS Standard/Enterprise customers only.
+# Purchase or obtain a trial license at https://openfaas.com/pricing/
 
 # You will need to create a license named "openfaas-license" - see the
 # chart README for detailed instructions.

diff --git a/chart/sqs-connector/values.yaml b/chart/sqs-connector/values.yaml
@@ -1,6 +1,5 @@
-# The Kafka connector is an OpenFaaS Pro feature
-#
-# Purchase a license at https://openfaas.com/support/
+# This component is licensed for OpenFaaS Standard/Enterprise customers only.
+# Purchase or obtain a trial license at https://openfaas.com/pricing/
 
 # You will need to create a license named "openfaas-license" - see the
 # chart README for detailed instructions.