The client can still be useful for some tasks even if it can't maintain a complete list of topics due to e.g. Kafka 0.10's new ACLs. Fixes #722.
@@ -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: