[incubator/kafka] Change internal advertise lisiner to pod name instead IP (#10817)

Signed-off-by: Karol Chrapek <kchrapek@novomatic-tech.com>
This commit is contained in:
Karol Chrapek
2019-01-23 06:27:06 -08:00
committed by Kubernetes Prow Robot
parent 0077ae7f26
commit e77ec787e0
2 changed files with 8 additions and 4 deletions
+1 -1
View File
@@ -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
+7 -3
View File
@@ -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