fix: When set to controller only, port 9092 is not listened on (#1218)

Author: Kazuhiko Yamashita

Diff for: sentry/templates/_helper.tpl

@@ -410,6 +410,17 @@ Set Kafka Confluent port
 {{- end -}}
 {{- end -}}
 
+{{/*
+Set Kafka Confluent Controller port
+*/}}
+{{- define "sentry.kafka.controller_port" -}}
+{{- if and (.Values.kafka.enabled) (.Values.kafka.service.ports.controller ) -}}
+{{- .Values.kafka.service.ports.controller }}
+{{- else if and (.Values.externalKafka) (not (kindIs "slice" .Values.externalKafka)) -}}
+{{ required "A valid .Values.externalKafka.port is required" .Values.externalKafka.port }}
+{{- end -}}
+{{- end -}}
+
 {{/*
 Set Kafka bootstrap servers string
 */}}

Diff for: sentry/templates/hooks/sentry-db-check.job.yaml

@@ -3,6 +3,7 @@
 {{- $clickhousePort := include "sentry.clickhouse.port" . -}}
 {{- $kafkaHost := include "sentry.kafka.host" . -}}
 {{- $kafkaPort := include "sentry.kafka.port" . -}}
+{{- $kafkaControllerPort := include "sentry.kafka.controller_port" . -}}
 apiVersion: batch/v1
 kind: Job
 metadata:
@@ -140,7 +141,7 @@ spec:
                 KRAFT_STATUS=1
                 i=0; while [ $i -lt $KAFKA_REPLICAS ]; do
                   KRAFT_HOST={{ $kafkaHost }}-controller-$i.{{ $kafkaHost }}-controller-headless
-                  if ! nc -z "$KRAFT_HOST" {{ $kafkaPort }}; then
+                  if ! nc -z "$KRAFT_HOST" {{ $kafkaControllerPort }}; then
                     KRAFT_STATUS=0
                     echo "$KRAFT_HOST is not available yet"
                   fi