normalize kafka user name

nasark · Jan 21, 2024 · 8d6201c · 8d6201c
1 parent da480ea
commit 8d6201c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/manageiq-operator/api/v1alpha1/helpers/miq-components/kafka/kafka.go b/manageiq-operator/api/v1alpha1/helpers/miq-components/kafka/kafka.go
@@ -192,7 +192,7 @@ func MessagingEnvSecret(cr *miqv1alpha1.ManageIQ, client client.Client, scheme *
 		if err := controllerutil.SetControllerReference(cr, secret, scheme); err != nil {
 			return err
 		}
-		secretKey := types.NamespacedName{Namespace: cr.ObjectMeta.Namespace, Name: cr.Spec.AppName + "-user"}
+		secretKey := types.NamespacedName{Namespace: cr.ObjectMeta.Namespace, Name: cr.Spec.AppName + "-kafka-admin"}
 		kafkaUser := &corev1.Secret{}
 		secretErr := client.Get(context.TODO(), secretKey, kafkaUser)
 		if secretErr != nil {
@@ -487,7 +487,7 @@ func KafkaUser(cr *miqv1alpha1.ManageIQ, scheme *runtime.Scheme) (*unstructured.
 		Kind:    "KafkaUser",
 		Version: "v1beta2",
 	})
-	kafkaUserCR.SetName(cr.Spec.AppName + "-user")
+	kafkaUserCR.SetName(cr.Spec.AppName + "-kafka-admin")
 	kafkaUserCR.SetNamespace(cr.Namespace)
 	kafkaUserCR.SetLabels(map[string]string{"strimzi.io/cluster": cr.Spec.AppName})