Skip to content

Commit

Permalink
[test] second coordinator call
Browse files Browse the repository at this point in the history
  • Loading branch information
wvanbergen committed Apr 9, 2015
1 parent c7bcd38 commit 5f3ea66
Showing 1 changed file with 19 additions and 0 deletions.
19 changes: 19 additions & 0 deletions functional_client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}

0 comments on commit 5f3ea66

Please sign in to comment.