Get Kafka AdminClient from envVars (#524)

Signed-off-by: Stanislav Knot <sknot@redhat.com>
strimzi · Jun 2, 2021 · e24a57f · e24a57f
1 parent 387f424
commit e24a57f
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/bin/docker/kafka_bridge_config_generator.sh b/bin/docker/kafka_bridge_config_generator.sh
@@ -117,6 +117,17 @@ EOF
 )
 done
 
+ADMIN_CLIENT_PROPERTIES="#Apache Kafka AdminClient"
+for i in $KAFKA_BRIDGE_ADMIN_CLIENT_CONFIG; do
+        key="kafka.admin.$(echo $i | cut -d'=' -f1)"
+        value="$(echo -n $i | cut -d'=' -f2)"
+        ADMIN_CLIENT_PROPERTIES=$(cat <<EOF
+$ADMIN_CLIENT_PROPERTIES
+${key}=${value}
+EOF
+)
+done
+
 HTTP_PROPERTIES=$(cat <<-EOF
 #HTTP configuration
 http.enabled=${KAFKA_BRIDGE_HTTP_ENABLED}
@@ -145,6 +156,8 @@ $BRIDGE_PROPERTIES
 
 $KAFKA_PROPERTIES
 
+$ADMIN_CLIENT_PROPERTIES
+
 $PRODUCER_PROPERTIES
 
 $CONSUMER_PROPERTIES