Browse Source

Retry UnknownTopicOrPartition on fetching metadata

Evan Huus 10 năm trước cách đây
mục cha
commit
9ffa8c742f
1 tập tin đã thay đổi với 1 bổ sung1 xóa
  1. 1 1
      client.go

+ 1 - 1
client.go

@@ -561,7 +561,7 @@ func (client *Client) update(data *MetadataResponse) ([]string, error) {
 		switch topic.Err {
 		switch topic.Err {
 		case ErrNoError:
 		case ErrNoError:
 			break
 			break
-		case ErrLeaderNotAvailable:
+		case ErrLeaderNotAvailable, ErrUnknownTopicOrPartition:
 			toRetry[topic.Name] = true
 			toRetry[topic.Name] = true
 		default:
 		default:
 			err = topic.Err
 			err = topic.Err