diff --git a/src/server/pachyderm_test.go b/src/server/pachyderm_test.go
index <HASH>..<HASH> 100644
--- a/src/server/pachyderm_test.go
+++ b/src/server/pachyderm_test.go
@@ -8311,9 +8311,9 @@ func TestKafka(t *testing.T) {
 	time.Sleep(20 * time.Second)
 
 	host := os.Getenv("KAFKA_IP")
-	if host == "" {
-		host = "0.0.0.0"
-	}
+	// if host == "" {
+	host = "0.0.0.0"
+	// }
 	// Open a connection to the kafka cluster
 	conn, err := kafka.Dial("tcp", fmt.Sprintf("%v:%v", host, 32400))
 	if err != nil {
see if it actually needs the KAFKA_IP