From 5f3ea66ff97186e52522522e3e592e9ed86e48b9 Mon Sep 17 00:00:00 2001 From: Willem van Bergen Date: Thu, 9 Apr 2015 11:37:37 -0400 Subject: [PATCH] [test] second coordinator call --- functional_client_test.go | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/functional_client_test.go b/functional_client_test.go index b4a6457ac..131d612de 100644 --- a/functional_client_test.go +++ b/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) }