Commit fb30ffd2 authored by Waleed Akbar's avatar Waleed Akbar
Browse files

updated Kafka deployment script.

-
parent d41319c7
Loading
Loading
Loading
Loading
+5 −3
Original line number Diff line number Diff line
@@ -78,11 +78,13 @@ function kafka_deploy() {

echo "Apache Kafka"
echo ">>> Checking if Apache Kafka is deployed ... "
if [ "$KFK_REDEPLOY" == "YES" ]; then
if [ "$KFK_REDEPLOY" = "YES" ]; then
    echo ">>> Redeploying kafka namespace"
    kafka_deploy
elif kubectl get --namespace ${KFK_NAMESPACE} deployments.apps &> /dev/null; then
elif kubectl get namespace "${KFK_NAMESPACE}" &> /dev/null; then
    echo ">>> Apache Kafka already present; skipping step." 
else
    echo ">>> Kafka namespace doesn't exists. Deploying kafka namespace"
    kafka_deploy
fi
echo