Merge pull request #21 from RADAR-base/kafka-wait-ssl

add support for kafka properties in kafka-wait

docker/kafka-wait

@@ -2,6 +2,24 @@
 
 max_timeout=32
 
+IS_TEMP=0
+
+if [ -n "$COMMAND_CONFIG_FILE_PATH" ]; then
+    COMMAND_CONFIG_FILE_PATH="$(mktemp)"
+    IS_TEMP=1
+fi
+
+if [ ! -f "$COMMAND_CONFIG_FILE_PATH" ] || [ $IS_TEMP = 1 ]; then
+    while IFS='=' read -r -d '' n v; do
+        if [[ "$n" == "CONNECT_"* ]]; then
+            name="${n/CONNECT_/""}" # remove first "CONNECT_"
+            name="${name,,}" # lower case
+            name="${name//_/"."}" # replace all '_' with '.'
+            echo "$name=$v" >> ${COMMAND_CONFIG_FILE_PATH}
+        fi
+    done < <(env -0)
+fi
+
 # Check if variables exist
 if [ -z "$CONNECT_BOOTSTRAP_SERVERS" ]; then
     echo "CONNECT_BOOTSTRAP_SERVERS is not defined"
@@ -11,7 +29,7 @@ else
     tries=10
     timeout=1
     while true; do
-        KAFKA_CHECK=$(kafka-broker-api-versions --bootstrap-server "$CONNECT_BOOTSTRAP_SERVERS" | grep "(id: " | wc -l)
+        KAFKA_CHECK=$(kafka-broker-api-versions --bootstrap-server "$CONNECT_BOOTSTRAP_SERVERS" --command-config "${COMMAND_CONFIG_FILE_PATH}" | grep "(id: " | wc -l)
 
         if [ "$KAFKA_CHECK" -ge "$KAFKA_BROKERS" ]; then
             echo "Kafka brokers available."
@@ -57,3 +75,7 @@ else
 
     echo "Schema registry is available."
 fi
+
+if [ $IS_TEMP = 1 ]; then
+    /bin/rm -f "$COMMAND_CONFIG_FILE_PATH"
+fi