From 8b8c3866cae3c9b2fdafd515c3f62ae6dc11b4f4 Mon Sep 17 00:00:00 2001 From: rustco Date: Mon, 3 Mar 2025 18:06:33 +0800 Subject: [PATCH] fix: fix the wrong error return value Signed-off-by: rustco --- pkg/admin/zkclient.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/admin/zkclient.go b/pkg/admin/zkclient.go index d46697a3..417fd507 100644 --- 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,