diff --git a/apps/emqx_resource/src/emqx_resource_metrics.erl b/apps/emqx_resource/src/emqx_resource_metrics.erl
index 97a09b074..98a74dfad 100644
--- a/apps/emqx_resource/src/emqx_resource_metrics.erl
+++ b/apps/emqx_resource/src/emqx_resource_metrics.erl
@@ -17,6 +17,7 @@
 -module(emqx_resource_metrics).
 
 -include_lib("emqx/include/logger.hrl").
+-include("emqx_resource.hrl").
 
 -export([
     events/0,
@@ -74,7 +75,6 @@
     success_get/1
 ]).
 
--define(RES_METRICS, resource_metrics).
 -define(TELEMETRY_PREFIX, emqx, resource).
 
 -spec events() -> [telemetry:event_name()].
@@ -127,15 +127,19 @@ handle_telemetry_event(
             %% We catch errors to avoid detaching the telemetry handler function.
             %% When restarting a resource while it's under load, there might be transient
             %% failures while the metrics are not yet created.
-            ?SLOG(warning, #{
-                msg => "handle_resource_metrics_failed",
-                hint => "transient failures may occur when restarting a resource",
-                kind => Kind,
-                reason => Reason,
-                stacktrace => Stacktrace,
-                resource_id => ID,
-                event => Event
-            }),
+            ?SLOG(
+                warning,
+                #{
+                    msg => "handle_resource_metrics_failed",
+                    hint => "transient failures may occur when restarting a resource",
+                    kind => Kind,
+                    reason => Reason,
+                    stacktrace => Stacktrace,
+                    resource_id => ID,
+                    event => Event
+                },
+                #{tag => ?TAG}
+            ),
             ok
     end;
 handle_telemetry_event(
@@ -151,15 +155,19 @@ handle_telemetry_event(
             %% We catch errors to avoid detaching the telemetry handler function.
             %% When restarting a resource while it's under load, there might be transient
             %% failures while the metrics are not yet created.
-            ?SLOG(warning, #{
-                msg => "handle_resource_metrics_failed",
-                hint => "transient failures may occur when restarting a resource",
-                kind => Kind,
-                reason => Reason,
-                stacktrace => Stacktrace,
-                resource_id => ID,
-                event => Event
-            }),
+            ?SLOG(
+                warning,
+                #{
+                    msg => "handle_resource_metrics_failed",
+                    hint => "transient failures may occur when restarting a resource",
+                    kind => Kind,
+                    reason => Reason,
+                    stacktrace => Stacktrace,
+                    resource_id => ID,
+                    event => Event
+                },
+                #{tag => ?TAG}
+            ),
             ok
     end;
 handle_telemetry_event(_EventName, _Measurements, _Metadata, _HandlerConfig) ->