[test] second coordinator call

functional_client_test.go

@@ -79,4 +79,23 @@ func TestFuncClientCoordinator(t *testing.T) {
 	}
 
 	safeClose(t, client)
+
+	config = NewConfig()
+	config.Metadata.Retry.Max = 10
+	config.Metadata.Retry.Backoff = 100 * time.Second
+	client, err = NewClient(kafkaBrokers, config)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	broker, err = client.Coordinator("another_new_consumer_group")
+	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())
+	}
+
+	safeClose(t, client)
 }