fix: fix always update EMQX config

Signed-off-by: Rory Z <[email protected]>
emqx · Feb 22, 2024 · 0700113 · 0700113
1 parent d723276
commit 0700113
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/controllers/apps/v2beta1/sync_emqx_config.go b/controllers/apps/v2beta1/sync_emqx_config.go
@@ -50,7 +50,7 @@ func (s *syncConfig) reconcile(ctx context.Context, logger logr.Logger, instance
 		if instance.Annotations == nil {
 			instance.Annotations = map[string]string{}
 		}
-		instance.Annotations[appsv2beta1.AnnotationsLastEMQXConfigKey] = confStr
+		instance.Annotations[appsv2beta1.AnnotationsLastEMQXConfigKey] = instance.Spec.Config.Data
 		if err := s.Client.Update(ctx, instance); err != nil {
 			return subResult{err: emperror.Wrap(err, "failed to update emqx instance annotation")}
 		}
@@ -91,7 +91,7 @@ func (s *syncConfig) reconcile(ctx context.Context, logger logr.Logger, instance
 			return subResult{err: emperror.Wrap(err, "failed to update configMap")}
 		}
 
-		instance.Annotations[appsv2beta1.AnnotationsLastEMQXConfigKey] = confStr
+		instance.Annotations[appsv2beta1.AnnotationsLastEMQXConfigKey] = instance.Spec.Config.Data
 		if err := s.Client.Update(ctx, instance); err != nil {
 			return subResult{err: emperror.Wrap(err, "failed to update emqx instance annotation")}
 		}