test: reduce flakiness

emqx · Feb 29, 2024 · 5d94a91 · 5d94a91
1 parent 16b3dc1
commit 5d94a91
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -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
     ),