fix: error message

goto · Sep 6, 2024 · 1cd8b94 · 1cd8b94
1 parent 75f2365
commit 1cd8b94
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/modules/kafka/config.go b/modules/kafka/config.go
@@ -40,12 +40,12 @@ func readConfig(res resource.Resource, confJSON json.RawMessage, dc driverConf)
 	var resCfg, cfg Config
 
 	if err := json.Unmarshal(confJSON, &cfg); err != nil {
-		return nil, errors.ErrInvalid.WithMsgf("invalid config json").WithCausef(err.Error())
+		return nil, errors.ErrInvalid.WithMsgf("failed to unmarshal").WithCausef(err.Error())
 	}
 
 	if res.Spec.Configs != nil {
 		if err := json.Unmarshal(res.Spec.Configs, &resCfg); err != nil {
-			return nil, errors.ErrInvalid.WithMsgf("invalid config json").WithCausef(err.Error())
+			return nil, errors.ErrInvalid.WithMsgf("failed to unmarshal").WithCausef(err.Error())
 		}
 	}
 
@@ -63,7 +63,7 @@ func readConfig(res resource.Resource, confJSON json.RawMessage, dc driverConf)
 
 	newConfJSON, err := json.Marshal(cfg)
 	if err != nil {
-		return nil, errors.ErrInvalid.WithMsgf("invalid config json").WithCausef(err.Error())
+		return nil, errors.ErrInvalid.WithMsgf("failed to marshal").WithCausef(err.Error())
 	}
 
 	if err := validateConfig(newConfJSON); err != nil {