diff --git a/client.go b/client.go index e30e8d3559..2b28842242 100644 --- a/client.go +++ b/client.go @@ -591,13 +591,9 @@ func (client *client) updateMetadata(data *MetadataResponse) ([]string, error) { client.cachedPartitionsResults[topic.Name] = partitionCache } - if err != nil { - return nil, err - } - ret := make([]string, 0, len(toRetry)) for topic := range toRetry { ret = append(ret, topic) } - return ret, nil + return ret, err }