Browse Source

Process partition metadata in event of topic-level error

As per 1b465e78c274a76c0a522272cac25e39ddaa0d07, "I can't think of a case where
the stale data from the last "complete" update is somehow more useful than the
up-to-date partial data."
Evan Huus 11 years ago
parent
commit
fe696f85ab
1 changed files with 0 additions and 2 deletions
  1. 0 2
      client.go

+ 0 - 2
client.go

@@ -537,10 +537,8 @@ func (client *Client) update(data *MetadataResponse) ([]string, error) {
 			break
 			break
 		case LeaderNotAvailable:
 		case LeaderNotAvailable:
 			toRetry[topic.Name] = true
 			toRetry[topic.Name] = true
-			continue
 		default:
 		default:
 			err = topic.Err
 			err = topic.Err
-			continue
 		}
 		}
 
 
 		client.metadata[topic.Name] = make(map[int32]*PartitionMetadata, len(topic.Partitions))
 		client.metadata[topic.Name] = make(map[int32]*PartitionMetadata, len(topic.Partitions))