Fix test

IBM · Jul 3, 2018 · 5d35641 · 5d35641
1 parent b836493
commit 5d35641
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/client_test.go b/client_test.go
@@ -481,10 +481,11 @@ func TestClientController(t *testing.T) {
 		t.Fatal(err)
 	}
 	defer safeClose(t, client2)
-	if _, err = client2.Controller(); err != ErrControllerNotAvailable {
-		t.Errorf("Expected Contoller() to return %s, found %s", ErrControllerNotAvailable, err)
+	if _, err = client2.Controller(); err != ErrUnsupportedVersion {
+		t.Errorf("Expected Contoller() to return %s, found %s", ErrUnsupportedVersion, err)
 	}
 }
+
 func TestClientCoordinatorWithConsumerOffsetsTopic(t *testing.T) {
 	seedBroker := NewMockBroker(t, 1)
 	staleCoordinator := NewMockBroker(t, 2)