fix: fix the wrong error return value (#223)

rustco · web-flow · commit 3a2269ff468e · 2025-03-03T09:53:10.000-05:00
Signed-off-by: rustco &lt;ruster@111.com&gt;
diff --git a/pkg/admin/zkclient.go b/pkg/admin/zkclient.go
@@ -944,7 +944,7 @@ func (c *ZKAdminClient) getTopic(
 	for i := 0; i < len(zkTopicInfo.Partitions); i++ {
 		partitionResp := <-partitionRespChan
 		if partitionResp.err != nil {
-			return topicInfo, err
+			return topicInfo, partitionResp.err
 		}
 		topicInfo.Partitions = append(
 			topicInfo.Partitions,

Original file line number	Diff line number	Diff line change
`@@ -944,7 +944,7 @@ func (c *ZKAdminClient) getTopic(`
`944`	`944`	`for i := 0; i < len(zkTopicInfo.Partitions); i++ {`
`945`	`945`	`partitionResp := <-partitionRespChan`
`946`	`946`	`if partitionResp.err != nil {`
`947`		`- return topicInfo, err`
	`947`	`+ return topicInfo, partitionResp.err`
`948`	`948`	`}`
`949`	`949`	`topicInfo.Partitions = append(`
`950`	`950`	`topicInfo.Partitions,`