소스 검색

test(kafka): try to stabilize `t_dynamic_mqtt_topic/1` testcase

Andrew Mayorov 2 년 전
부모
커밋
5fff2ffe45
1개의 변경된 파일1개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl

+ 1 - 0
apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl

@@ -1707,6 +1707,7 @@ t_dynamic_mqtt_topic(Config) ->
                 create_bridge(Config)
                 create_bridge(Config)
             ),
             ),
             wait_until_subscribers_are_ready(NPartitions, 40_000),
             wait_until_subscribers_are_ready(NPartitions, 40_000),
+            ping_until_healthy(Config, _Period = 1_500, _Timeout = 24_000),
             {ok, C} = emqtt:start_link(),
             {ok, C} = emqtt:start_link(),
             on_exit(fun() -> emqtt:stop(C) end),
             on_exit(fun() -> emqtt:stop(C) end),
             {ok, _} = emqtt:connect(C),
             {ok, _} = emqtt:connect(C),