diff --git a/client.go b/client.go index b8fc37bc7..e9a9ea77e 100644 --- a/client.go +++ b/client.go @@ -138,7 +138,7 @@ func NewClient(addrs []string, conf *Config) (Client, error) { switch err { case nil: break - case ErrLeaderNotAvailable, ErrReplicaNotAvailable: + case ErrLeaderNotAvailable, ErrReplicaNotAvailable, ErrTopicAuthorizationFailed, ErrClusterAuthorizationFailed: // indicates that maybe part of the cluster is down, but is not fatal to creating the client Logger.Println(err) default: