diff --git a/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl b/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl
index fe7353f68..23a8b4828 100644
--- a/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl
+++ b/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl
@@ -2090,7 +2090,9 @@ t_begin_offset_earliest(Config) ->
                 ),
                 #{payloads => Payloads}
             ),
-            ?assertEqual(NumMessages, emqx_resource_metrics:received_get(ResourceId)),
+            ?retry(
+                100, 20, ?assertEqual(NumMessages, emqx_resource_metrics:received_get(ResourceId))
+            ),
             ok
         end
     ),