Bitnami/charts
2
0
Fork 0
mirror of https://github.com/bitnami/charts.git synced 2026-03-27 15:27:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

[bitnami/kafka][bitnami/charts/issues/32851] Update controller and broker configuration when enabling controller.controllerOnly (#33740)

Browse Source 
* [bitnami/kafka][bitnami/charts/issues/32851] Update controller and broker configuration when enabling controller.controllerOnly

Signed-off-by: Jota Martos <jotamartos@vmware.com>

* [bitnami/kafka][bitnami/charts/issues/32851] Bump version

Signed-off-by: Jota Martos <jotamartos@vmware.com>

* Apply suggestions

Signed-off-by: Jota Martos <jotamartos@vmware.com>

* Update CHANGELOG.md

Signed-off-by: Bitnami Bot <bitnami.bot@broadcom.com>

---------

Signed-off-by: Jota Martos <jotamartos@vmware.com>
Signed-off-by: Bitnami Bot <bitnami.bot@broadcom.com>
Co-authored-by: Bitnami Bot <bitnami.bot@broadcom.com>
This commit is contained in:
Juan José Martos
2025-05-19 13:13:02 +02:00
committed by GitHub
parent cd9a26e511
commit bfcd44f0c6
6 changed files with 18 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
bitnami/kafka/templates/_helpers.tpl
View File

@@ -485,23 +485,16 @@ Returns the value listener.security.protocol.map based on the values of 'listene
{{- if .context.Values.listeners.securityProtocolMap -}}
{{- print .context.Values.listeners.securityProtocolMap -}}
{{- else -}}
{{- $listeners := list .context.Values.listeners.client .context.Values.listeners.interbroker -}}
{{- if .isController -}}
{{- if .context.Values.controller.controllerOnly -}}
{{- $listeners = list .context.Values.listeners.controller -}}
{{- else -}}
{{- $listeners = append $listeners .context.Values.listeners.controller -}}
{{- range $i := .context.Values.listeners.extraListeners -}}
{{- $listeners = append $listeners $i -}}
{{- end -}}
{{- end -}}
{{- $listeners := list .context.Values.listeners.controller .context.Values.listeners.client .context.Values.listeners.interbroker -}}
{{- if and .isController .context.Values.controller.controllerOnly -}}
{{- $listeners = list .context.Values.listeners.controller -}}
{{- else -}}
{{- range $i := .context.Values.listeners.extraListeners -}}
{{- $listeners = append $listeners $i -}}
{{- end -}}
{{- end -}}
{{- if and .context.Values.externalAccess.enabled -}}
{{- $listeners = append $listeners .context.Values.listeners.external -}}
{{- if .context.Values.externalAccess.enabled -}}
{{- $listeners = append $listeners .context.Values.listeners.external -}}
{{- end -}}
{{- $res := list -}}
{{- range $listener := $listeners -}}
@@ -546,7 +539,6 @@ Returns the controller quorum bootstrap servers based on the number of controlle
Section of the server.properties shared by both controller-eligible and broker nodes
*/}}
{{- define "kafka.commonConfig" -}}
inter.broker.listener.name: {{ .Values.listeners.interbroker.name }}
controller.listener.names: {{ .Values.listeners.controller.name }}
controller.quorum.bootstrap.servers: {{ include "kafka.controller.quorumBootstrapServers" . }}
{{- if include "kafka.sslEnabled" . }}

1
bitnami/kafka/templates/broker/configmap.yaml
View File

@@ -15,6 +15,7 @@ ref: https://kafka.apache.org/documentation/#configuration
listeners: {{ include "kafka.listeners" (dict "isController" false "context" .) }}
listener.security.protocol.map: {{ include "kafka.securityProtocolMap" (dict "isController" false "context" .) }}
advertised.listeners: {{ include "kafka.advertisedListeners" . }}
inter.broker.listener.name: {{ .Values.listeners.interbroker.name }}
# Kafka data logs directory
log.dir: {{ printf "%s/data" .Values.broker.persistence.mountPath }}
# Kafka application logs directory

1
bitnami/kafka/templates/controller-eligible/configmap.yaml
View File

@@ -16,6 +16,7 @@ listeners: {{ include "kafka.listeners" (dict "isController" true "context" .) }
listener.security.protocol.map: {{ include "kafka.securityProtocolMap" (dict "isController" true "context" .) }}
{{- if not .Values.controller.controllerOnly }}
advertised.listeners: {{ include "kafka.advertisedListeners" . }}
inter.broker.listener.name: {{ .Values.listeners.interbroker.name }}
{{- end }}
# Kafka data logs directory
log.dir: {{ printf "%s/data" .Values.controller.persistence.mountPath }}