Yolo

functional_client_test.go

@@ -1,6 +1,7 @@
 package sarama
 
 import (
+	"fmt"
 	"testing"
 	"time"
 )
@@ -88,13 +89,15 @@ func TestFuncClientCoordinator(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	broker, err = client.Coordinator("another_new_consumer_group")
-	if err != nil {
-		t.Error(err)
-	}
+	for i := 0; i < 10; i++ {
+		broker, err = client.Coordinator(fmt.Sprintf("another_new_consumer_group_%d", i))
+		if err != nil {
+			t.Error(err)
+		}
 
-	if connected, err := broker.Connected(); !connected || err != nil {
-		t.Errorf("Expected to coordinator %s broker to be properly connected.", broker.Addr())
+		if connected, err := broker.Connected(); !connected || err != nil {
+			t.Errorf("Expected to coordinator %s broker to be properly connected.", broker.Addr())
+		}
 	}
 
 	safeClose(t, client)