From a844d4fad6b38dec5a2d0c31246e20fc7ebaf9c4 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Fri, 18 Dec 2015 11:17:27 -0800
Subject: [PATCH] Remove old kafka-bin directory and verify kafka-run-class.sh
 exists when installing server artifacts

---
 build_integration.sh | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/build_integration.sh b/build_integration.sh
index ef4c869..613c291 100755
--- a/build_integration.sh
+++ b/build_integration.sh
@@ -40,6 +40,7 @@ pushd servers
         # Not sure how to construct the .tgz name accurately, so use a wildcard (ugh)
         tar xzvf $kafka/core/build/distributions/kafka_*.tgz -C ../$kafka/
         rm $kafka/core/build/distributions/kafka_*.tgz
+        rm -rf ../$kafka/kafka-bin
         mv ../$kafka/kafka_* ../$kafka/kafka-bin
       else
         echo "-------------------------------------"
@@ -57,7 +58,12 @@ pushd servers
           echo
           echo "Extracting kafka ${kafka} binaries"
           tar xzvf ${KAFKA_ARTIFACT}.t* -C ../$kafka/
+          rm -rf ../$kafka/kafka-bin
           mv ../$kafka/${KAFKA_ARTIFACT} ../$kafka/kafka-bin
+          if [ ! -f "../$kafka/kafka-bin/bin/kafka-run-class.sh" ]; then
+            echo "Extraction Failed ($kafka/kafka-bin/bin/kafka-run-class.sh does not exist)!"
+            exit 1
+          fi
         else
           echo "$kafka is already installed in servers/$kafka/ -- skipping"
         fi