diff --git a/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_consumer_SUITE.erl b/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_consumer_SUITE.erl
index 2f66b9c0e..1372bf71c 100644
--- a/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_consumer_SUITE.erl
+++ b/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_consumer_SUITE.erl
@@ -363,10 +363,14 @@ t_custom_group_id(Config) ->
                     #{<<"parameters">> => #{<<"group_id">> => CustomGroupId}}
                 ),
             [Endpoint] = emqx_bridge_kafka_impl:hosts(BootstrapHosts),
-            ?assertMatch(
-                {ok, [{_, CustomGroupId, _}]},
-                brod:list_groups(Endpoint, _ConnOpts = #{})
-            ),
+            ?retry(100, 10, begin
+                {ok, Groups} = brod:list_groups(Endpoint, _ConnOpts = #{}),
+                ?assertMatch(
+                    [_],
+                    [Group || Group = {_, Id, _} <- Groups, Id == CustomGroupId],
+                    #{groups => Groups}
+                )
+            end),
             ok
         end,
         []