diff --git a/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/KafkaTestServer.java b/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/KafkaTestServer.java
index 85e7d21..2a3b317 100644
--- a/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/KafkaTestServer.java
+++ b/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/KafkaTestServer.java
@@ -39,10 +39,10 @@
     private File sentrySitePath = null;
 
     public KafkaTestServer(File sentrySitePath) throws Exception {
-        this.zkPort = TestUtils.getFreePort();
-        this.kafkaPort = TestUtils.getFreePort();
         this.sentrySitePath = sentrySitePath;
+        this.zkPort = TestUtils.getFreePort();
         createZkServer();
+        this.kafkaPort = TestUtils.getFreePort();
         createKafkaServer();
     }
 
diff --git a/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/TestUtils.java b/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/TestUtils.java
index dda4047..5d36082 100644
--- a/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/TestUtils.java
+++ b/sentry-tests/sentry-tests-kafka/src/main/java/org/apache/sentry/tests/e2e/kafka/TestUtils.java
@@ -23,7 +23,9 @@
     public static int getFreePort() throws IOException {
         synchronized (TestUtils.class) {
             ServerSocket serverSocket = new ServerSocket(0);
-            return serverSocket.getLocalPort();
+            int port = serverSocket.getLocalPort();
+            serverSocket.close();
+            return port;
         }
     }
 }