This is an automated email from the ASF dual-hosted git repository.
dgrove pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/openwhisk-deploy-kube.git
The following commit(s) were added to refs/heads/master by this push:
new 9492344 upgrade kafka server from 0.11.0.1 to 2.3.1 (#582)
9492344 is described below
commit 9492344ae515fddcaf6c92eee81645fcac0f959a
Author: David Grove <[email protected]>
AuthorDate: Wed Feb 12 18:17:08 2020 -0500
upgrade kafka server from 0.11.0.1 to 2.3.1 (#582)
Matches core PR#4802 which upgrade the ansible-based
deployment to kafka version 2.3.1.
---
helm/openwhisk/templates/kafka-pod.yaml | 14 +++++++++++++-
helm/openwhisk/values.yaml | 2 +-
2 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/helm/openwhisk/templates/kafka-pod.yaml
b/helm/openwhisk/templates/kafka-pod.yaml
index bb49a8d..170b93e 100644
--- a/helm/openwhisk/templates/kafka-pod.yaml
+++ b/helm/openwhisk/templates/kafka-pod.yaml
@@ -64,7 +64,7 @@ spec:
- name: kafka
image: "{{- .Values.docker.registry.name -}}{{-
.Values.kafka.imageName -}}:{{- .Values.kafka.imageTag -}}"
imagePullPolicy: {{ .Values.kafka.imagePullPolicy | quote }}
- command: ["/bin/bash", "-c", "export KAFKA_BROKER_ID=`hostname | awk
-F '-' '{print $NF}'`; export KAFKA_ADVERTISED_HOST_NAME=`hostname -f`;
/usr/bin/start-kafka.sh"]
+ command: ["/bin/bash", "-c", "export KAFKA_BROKER_ID=`hostname | awk
-F '-' '{print $NF}'`; /usr/bin/start-kafka.sh"]
{{- if .Values.k8s.persistence.enabled }}
volumeMounts:
- mountPath: /kafka
@@ -74,8 +74,20 @@ spec:
- containerPort: {{ .Values.kafka.port }}
name: kafka
env:
+ - name: "HOSTNAME_COMMAND"
+ value: "hostname -f"
- name: "KAFKA_ADVERTISED_PORT"
value: "{{ .Values.kafka.port }}"
+ - name: "KAFKA_PORT"
+ value: "{{ .Values.kafka.port }}"
+ - name: "KAFKA_LISTENER_SECURITY_PROTOCOL_MAP"
+ value: "EXTERNAL:PLAINTEXT"
+ - name: "KAFKA_LISTENERS"
+ value: "EXTERNAL://:{{ .Values.kafka.port }}"
+ - name: "KAFKA_ADVERTISED_LISTENERS"
+ value: "EXTERNAL://_{HOSTNAME_COMMAND}:{{ .Values.kafka.port }}"
+ - name: "KAFKA_INTER_BROKER_LISTENER_NAME"
+ value: "EXTERNAL"
# zookeeper info
- name: "KAFKA_ZOOKEEPER_CONNECT"
diff --git a/helm/openwhisk/values.yaml b/helm/openwhisk/values.yaml
index c155d26..17c9e20 100644
--- a/helm/openwhisk/values.yaml
+++ b/helm/openwhisk/values.yaml
@@ -188,7 +188,7 @@ zookeeper:
# kafka configurations
kafka:
imageName: "wurstmeister/kafka"
- imageTag: "0.11.0.1"
+ imageTag: "2.12-2.3.1"
imagePullPolicy: "IfNotPresent"
replicaCount: 1
restartPolicy: "Always"
