++

apps/message-hub/base/message-hub.yaml

@@ -166,9 +166,9 @@ spec:
               {{- $buckets := index .Data.data "buckets" }}
               S3_BUCKET={{- if gt (len $buckets) 0 -}}{{ index (index $buckets 0) "name" }}{{- else -}}rfi{{- end -}}
               {{- end -}}
-            vault.hashicorp.com/agent-inject-secret-message-hub-kafka: secrets/data/kafka/apps/message-hub
+            vault.hashicorp.com/agent-inject-secret-message-hub-kafka: secrets/data/kafka/apps/pm
             vault.hashicorp.com/agent-inject-template-message-hub-kafka: |-
-              {{- with secret "secrets/data/kafka/apps/message-hub" -}}
+              {{- with secret "secrets/data/kafka/apps/pm" -}}
               KAFKA_USERNAME={{ index .Data.data "username" }}
               KAFKA_PASSWORD={{ index .Data.data "password" }}
               KAFKA_HOST=kafka-kafka-contour-controller-headless.kafka.svc.cluster.local

apps/message-hub/d8-ugmk-prod/message-hub.yaml

@@ -86,19 +86,20 @@ spec:
             value:
               _default: "0"
 
-          # ВНИМАНИЕ: значение не подтверждено. В base было захардкожено
-          # kafka-kafka-contour-controller-headless — имя из другого контура,
-          # здесь HelmRelease называется kafka (infrastructure/kafka/d8-ugmk-prod).
-          # Проверить: kubectl -n kafka get svc
+          # Подтверждено: kubectl -n kafka get svc →
+          # kafka-kafka-contour-controller-headless.kafka.svc.cluster.local,
+          # порты 9094/9092/9093. 9094 — единственный клиентский листенер
+          # (listeners.client: SASL_SSL в infrastructure/kafka/d8-ugmk-prod/kafka.yaml),
+          # то же значение, что и в base, и в bootstrap_servers секрета pm.
           # Задано переменной, а не vault-шаблоном, специально: ошибка в шаблоне
           # блокирует старт пода (agent-init-first), ошибка в env — только логи.
           - name: KAFKA_HOST
             value:
-              _default: "kafka-controller-headless.kafka.svc.cluster.local"
+              _default: "kafka-kafka-contour-controller-headless.kafka.svc.cluster.local"
 
           - name: KAFKA_PORT
             value:
-              _default: "9092"
+              _default: "9094"
 
           # listeners.client.protocol: SASL_SSL — без CA соединение не поднимется.
           - name: KAFKA_SSL_CAFILE