Fix wrong log dir names

vivekjain123 · Dec 19, 2018 · e808c14 · e808c14
1 parent 0bec2cf
commit e808c14
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/charts/cp-kafka/templates/_helpers.tpl b/charts/cp-kafka/templates/_helpers.tpl
@@ -55,11 +55,12 @@ else use user-provided URL
 {{- end -}}
 
 {{/*
-Create a variable containing a comma-sepparated list of all the log dirs.
+Create a variable containing all the datadirs created.
 */}}
+
 {{- define "cp-kafka.log.dirs" -}}
 {{- range $k, $e := until (.Values.persistence.disksPerBroker|int) -}}
 {{- if $k}}{{- printf ","}}{{end}}
-{{- printf "/opt/kafka/data/logs-%d" $k -}}
+{{- printf "/opt/kafka/data-%d" $k -}}
 {{- end -}}
 {{- end -}}
diff --git a/charts/cp-kafka/templates/statefulset.yaml b/charts/cp-kafka/templates/statefulset.yaml
@@ -101,7 +101,6 @@ spec:
           value: {{ .Values.heapOptions }}
         - name: KAFKA_ZOOKEEPER_CONNECT
           value: {{ include "cp-kafka.cp-zookeeper.service-name" . | quote }}
-        {{- end }}
         {{- if not (hasKey .Values.configurationOverrides "log.dirs") }}
         - name: KAFKA_LOG_DIRS
           value: {{ include "cp-kafka.log.dirs" . | quote }}