浏览代码

Merge pull request #1211 from ming-relax/master

Makes code style consistent in kafka client after refresh metadata
Vlad Gorodetsky 6 年之前
父节点
当前提交
cbccf093cc
共有 1 个文件被更改,包括 2 次插入1 次删除
  1. 2 1
      client.go

+ 2 - 1
client.go

@@ -288,7 +288,8 @@ func (client *client) Partitions(topic string) ([]int32, error) {
 		partitions = client.cachedPartitions(topic, allPartitions)
 		partitions = client.cachedPartitions(topic, allPartitions)
 	}
 	}
 
 
-	if partitions == nil {
+	// no partitions found after refresh metadata
+	if len(partitions) == 0 {
 		return nil, ErrUnknownTopicOrPartition
 		return nil, ErrUnknownTopicOrPartition
 	}
 	}