From f4a626377cb2c5dee4cc644e941775138c9fbc80 Mon Sep 17 00:00:00 2001 From: Evan Huus Date: Thu, 11 Aug 2016 22:58:02 -0400 Subject: [PATCH] client: don't abort creation on auth failure 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. --- client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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: