From 6089eaa9e2b1441903f194c13d5f1233b70d56ae Mon Sep 17 00:00:00 2001
From: zhuliquan <zlq164114@sina.com>
Date: Mon, 15 May 2023 02:41:31 +0800
Subject: [PATCH] feature: return KError instead of errors in AlterConfigs and
 DescribeConfigs

Signed-off-by: zhuliquan <zlqlovecode@foxmail.com>
---
 admin.go                     | 10 ++--------
 alter_configs_response.go    | 18 +++++++++++++++++-
 describe_configs_response.go | 13 +++++++++++++
 3 files changed, 32 insertions(+), 9 deletions(-)

diff --git a/admin.go b/admin.go
index 29eeca1c6..89d34c4a3 100644
--- a/admin.go
+++ b/admin.go
@@ -684,11 +684,8 @@ func (ca *clusterAdmin) DescribeConfig(resource ConfigResource) ([]ConfigEntry,
 
 	for _, rspResource := range rsp.Resources {
 		if rspResource.Name == resource.Name {
-			if rspResource.ErrorMsg != "" {
-				return nil, errors.New(rspResource.ErrorMsg)
-			}
 			if rspResource.ErrorCode != 0 {
-				return nil, KError(rspResource.ErrorCode)
+				return nil, &DescribeConfigError{Err: KError(rspResource.ErrorCode), ErrMsg: rspResource.ErrorMsg}
 			}
 			for _, cfgEntry := range rspResource.Configs {
 				entries = append(entries, *cfgEntry)
@@ -739,11 +736,8 @@ func (ca *clusterAdmin) AlterConfig(resourceType ConfigResourceType, name string
 
 	for _, rspResource := range rsp.Resources {
 		if rspResource.Name == name {
-			if rspResource.ErrorMsg != "" {
-				return errors.New(rspResource.ErrorMsg)
-			}
 			if rspResource.ErrorCode != 0 {
-				return KError(rspResource.ErrorCode)
+				return &AlterConfigError{Err: KError(rspResource.ErrorCode), ErrMsg: rspResource.ErrorMsg}
 			}
 		}
 	}
diff --git a/alter_configs_response.go b/alter_configs_response.go
index 84cd86c72..3eb344ed5 100644
--- a/alter_configs_response.go
+++ b/alter_configs_response.go
@@ -1,6 +1,9 @@
 package sarama
 
-import "time"
+import (
+	"fmt"
+	"time"
+)
 
 // AlterConfigsResponse is a response type for alter config
 type AlterConfigsResponse struct {
@@ -8,6 +11,19 @@ type AlterConfigsResponse struct {
 	Resources    []*AlterConfigsResourceResponse
 }
 
+type AlterConfigError struct {
+	Err    KError
+	ErrMsg string
+}
+
+func (c *AlterConfigError) Error() string {
+	text := c.Err.Error()
+	if c.ErrMsg != "" {
+		text = fmt.Sprintf("%s - %s", text, c.ErrMsg)
+	}
+	return text
+}
+
 // AlterConfigsResourceResponse is a response type for alter config resource
 type AlterConfigsResourceResponse struct {
 	ErrorCode int16
diff --git a/describe_configs_response.go b/describe_configs_response.go
index 4968f4854..d0f4b4f80 100644
--- a/describe_configs_response.go
+++ b/describe_configs_response.go
@@ -34,6 +34,19 @@ const (
 	SourceDefault
 )
 
+type DescribeConfigError struct {
+	Err    KError
+	ErrMsg string
+}
+
+func (c *DescribeConfigError) Error() string {
+	text := c.Err.Error()
+	if c.ErrMsg != "" {
+		text = fmt.Sprintf("%s - %s", text, c.ErrMsg)
+	}
+	return text
+}
+
 type DescribeConfigsResponse struct {
 	Version      int16
 	ThrottleTime time.Duration