kafka broker hosts should be defined with a comma separated list

The broker attribute should use a comma separated list with the port
definition included

Example: kafka1:9092,kafka2:9092,kafka:9092

The kafka client will connect to the first available host this
will provide resiliency if a host is not available

Change-Id: I5f82e96f2aa274379b6d808291d4b5109709bf72
This commit is contained in:
Smith, David (ds3330) 2021-06-25 13:47:07 +00:00
parent 62f5cab770
commit 0ecb9bf288
3 changed files with 3 additions and 2 deletions

View File

@ -15,7 +15,7 @@ apiVersion: v1
appVersion: v1.10.1 appVersion: v1.10.1
description: OpenStack-Helm Fluentd description: OpenStack-Helm Fluentd
name: fluentd name: fluentd
version: 0.1.4 version: 0.1.5
home: https://www.fluentd.org/ home: https://www.fluentd.org/
sources: sources:
- https://github.com/fluent/fluentd - https://github.com/fluent/fluentd

View File

@ -26,7 +26,7 @@ tcpSocket:
{{- $kafkaBroker := tuple "kafka" "internal" . | include "helm-toolkit.endpoints.hostname_fqdn_endpoint_lookup" }} {{- $kafkaBroker := tuple "kafka" "internal" . | include "helm-toolkit.endpoints.hostname_fqdn_endpoint_lookup" }}
{{- $kafkaBrokerPort := tuple "kafka" "internal" "broker" . | include "helm-toolkit.endpoints.endpoint_port_lookup" }} {{- $kafkaBrokerPort := tuple "kafka" "internal" "broker" . | include "helm-toolkit.endpoints.endpoint_port_lookup" }}
{{- $kafkaBrokerURI := printf "%s:%s" $kafkaBroker $kafkaBrokerPort }} {{- $kafkaBrokerURI := printf "%s" $kafkaBroker }}
{{- $rcControllerName := printf "%s-%s" $envAll.Release.Name "fluentd" }} {{- $rcControllerName := printf "%s-%s" $envAll.Release.Name "fluentd" }}
{{ tuple $envAll "fluentd" $rcControllerName | include "helm-toolkit.snippets.kubernetes_pod_rbac_serviceaccount" }} {{ tuple $envAll "fluentd" $rcControllerName | include "helm-toolkit.snippets.kubernetes_pod_rbac_serviceaccount" }}

View File

@ -5,4 +5,5 @@ fluentd:
- 0.1.2 Add Configurable Readiness and Liveness Probes - 0.1.2 Add Configurable Readiness and Liveness Probes
- 0.1.3 Enable TLS path for output to Elasticsearch - 0.1.3 Enable TLS path for output to Elasticsearch
- 0.1.4 Use full image ref for docker official images - 0.1.4 Use full image ref for docker official images
- 0.1.5 Kafka brokers defined as a list with port "kafka1:9092,kafka2:9020,kafka3:9092"
... ...