Fixes errors not being handled

RedHatInsights · Jan 14, 2025 · 17a5866 · 17a5866
1 parent cac006b
commit 17a5866
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/controllers/cloud.redhat.com/providers/kafka/appinterface.go b/controllers/cloud.redhat.com/providers/kafka/appinterface.go
@@ -51,8 +51,15 @@ func (a *appInterface) setKafkaCA(broker *config.BrokerConfig) error {
 			return err
 		}
 
-		a.HashCache.CreateOrUpdateObject(&kafkaCASecret, true)
-		a.HashCache.AddClowdObjectToObject(a.Env, &kafkaCASecret)
+		_, err := a.HashCache.CreateOrUpdateObject(&kafkaCASecret, true)
+		if err != nil {
+			return err
+		}
+
+		err = a.HashCache.AddClowdObjectToObject(a.Env, &kafkaCASecret)
+		if err != nil {
+			return err
+		}
 
 		broker.Cacert = utils.StringPtr(string(kafkaCASecret.Data["ca.crt"]))
 		broker.Port = utils.IntPtr(9093)