diff --git a/deploy/kafka.sh b/deploy/kafka.sh
index 21ba89408e6bdadd92a2a96c59d6d24cd580952e..f8610801130bdfd198e112c8388d9ec7a34fffff 100755
--- a/deploy/kafka.sh
+++ b/deploy/kafka.sh
@@ -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
-    echo ">>> Apache Kafka already present; skipping step."
+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