From 0a8635cab6f1d765d01222fe885ac02154e0541f Mon Sep 17 00:00:00 2001
From: Kochetkov S <kochetkov.s@sarex.io>
Date: Tue, 21 Apr 2026 15:35:06 +0300
Subject: [PATCH] add kafka+minio

---
 .../bootstrap-jobs/service-bootstrap-jobs.yaml              | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/clusters/yc-k8s-test/infrastructure/bootstrap-jobs/service-bootstrap-jobs.yaml b/clusters/yc-k8s-test/infrastructure/bootstrap-jobs/service-bootstrap-jobs.yaml
index 3baa2e0..e3c375e 100644
--- a/clusters/yc-k8s-test/infrastructure/bootstrap-jobs/service-bootstrap-jobs.yaml
+++ b/clusters/yc-k8s-test/infrastructure/bootstrap-jobs/service-bootstrap-jobs.yaml
@@ -266,7 +266,7 @@ spec:
                       sasl.mechanism=PLAIN
                       sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username='inter_broker_user' password='${inter_broker_password}';
                       EOF
-                      kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
+                      /opt/bitnami/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
                         --alter --add-config 'SCRAM-SHA-512=[password=${password}],SCRAM-SHA-256=[password=${password}]' \
                         --entity-type users --entity-name '${username}'
                     " >/dev/null
@@ -279,13 +279,13 @@ spec:
                       [ -z "${topic_name}" ] && continue
 
                       kubectl -n kafka exec "${target_pod}" -c kafka -- /bin/bash -lc "\
-                        kafka-topics.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
+                        /opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
                           --create --if-not-exists --topic '${topic_name}' --partitions '${partitions}' --replication-factor '${replication_factor}'
                       " >/dev/null
 
                       if [ -n "${topic_configs}" ]; then
                         kubectl -n kafka exec "${target_pod}" -c kafka -- /bin/bash -lc "\
-                          kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
+                          /opt/bitnami/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
                             --alter --entity-type topics --entity-name '${topic_name}' --add-config '${topic_configs}'
                         " >/dev/null
                       fi