From e77ec787e028ad7c01d501b3b12a6749b1df220e Mon Sep 17 00:00:00 2001 From: Karol Chrapek Date: Wed, 23 Jan 2019 15:27:06 +0100 Subject: [PATCH] [incubator/kafka] Change internal advertise lisiner to pod name instead IP (#10817) Signed-off-by: Karol Chrapek --- incubator/kafka/Chart.yaml | 2 +- incubator/kafka/templates/statefulset.yaml | 10 +++++++--- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/incubator/kafka/Chart.yaml b/incubator/kafka/Chart.yaml index 975254c7eb..338d04088f 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.13.5 +version: 0.13.6 appVersion: 5.0.1 keywords: - kafka diff --git a/incubator/kafka/templates/statefulset.yaml b/incubator/kafka/templates/statefulset.yaml index 17e767b753..85cc3f5a90 100644 --- a/incubator/kafka/templates/statefulset.yaml +++ b/incubator/kafka/templates/statefulset.yaml @@ -158,10 +158,14 @@ spec: valueFrom: fieldRef: fieldPath: metadata.name - - name: POD_IP + - name: POD_NAME valueFrom: fieldRef: - fieldPath: status.podIP + fieldPath: metadata.name + - name: POD_NAMESPACE + valueFrom: + fieldRef: + fieldPath: metadata.namespace - name: KAFKA_HEAP_OPTS value: {{ .Values.kafkaHeapOptions }} {{- if not (hasKey .Values.configurationOverrides "zookeeper.connect") }} @@ -205,7 +209,7 @@ spec: - | unset KAFKA_PORT && \ export KAFKA_BROKER_ID=${POD_NAME##*-} && \ - export KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://${POD_IP}:9092{{ if kindIs "string" $advertisedListenersOverride }}{{ printf ",%s" $advertisedListenersOverride }}{{ 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: - name: datadir