diff --git a/incubator/kafka/Chart.yaml b/incubator/kafka/Chart.yaml index d207393703..59fef776db 100755 --- a/incubator/kafka/Chart.yaml +++ b/incubator/kafka/Chart.yaml @@ -2,7 +2,7 @@ apiVersion: v1 description: Apache Kafka is publish-subscribe messaging rethought as a distributed commit log. name: kafka -version: 0.14.5 +version: 0.14.6 appVersion: 5.0.1 keywords: - kafka diff --git a/incubator/kafka/templates/service-brokers-external.yaml b/incubator/kafka/templates/service-brokers-external.yaml index 7f227cbe7a..8d06c7c1b1 100644 --- a/incubator/kafka/templates/service-brokers-external.yaml +++ b/incubator/kafka/templates/service-brokers-external.yaml @@ -2,6 +2,7 @@ {{- $fullName := include "kafka.fullname" . }} {{- $replicas := .Values.replicas | int }} {{- $servicePort := .Values.external.servicePort }} + {{- $firstListenerPort := .Values.external.firstListenerPort }} {{- $dnsPrefix := printf "%s" .Release.Name }} {{- $root := . }} {{- range $i, $e := until $replicas }} @@ -45,12 +46,14 @@ spec: ports: - name: external-broker {{- if and (eq $root.Values.external.type "LoadBalancer") (not $root.Values.external.distinct) }} - port: {{ $externalListenerPort }} + port: {{ $firstListenerPort }} {{- else }} port: {{ $servicePort }} {{- end }} {{- if and (eq $root.Values.external.type "LoadBalancer") ($root.Values.external.distinct) }} targetPort: {{ $servicePort }} + {{- else if and (eq $root.Values.external.type "LoadBalancer") (not $root.Values.external.distinct) }} + targetPort: {{ $firstListenerPort }} {{- else }} targetPort: {{ $externalListenerPort }} {{- end }} diff --git a/incubator/kafka/templates/statefulset.yaml b/incubator/kafka/templates/statefulset.yaml index 93a8920f05..679d89002a 100644 --- a/incubator/kafka/templates/statefulset.yaml +++ b/incubator/kafka/templates/statefulset.yaml @@ -186,6 +186,9 @@ spec: - | unset KAFKA_PORT && \ export KAFKA_BROKER_ID=${POD_NAME##*-} && \ + {{- if eq .Values.external.type "LoadBalancer" }} + export LOAD_BALANCER_IP=$(echo '{{ .Values.external.loadBalancerIP }}' | tr -d '[]' | cut -d ' ' -f "$(($KAFKA_BROKER_ID + 1))") && \ + {{- end }} export KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://${POD_NAME}.{{ include "kafka.fullname" . }}-headless.${POD_NAMESPACE}:9092{{ if kindIs "string" $advertisedListenersOverride }}{{ printf ",%s" $advertisedListenersOverride }}{{ end }} && \ exec /etc/confluent/docker/run volumeMounts: