yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #11739 from keynslug/fix/flaky-kafka-testcase 

test(kafka): try to stabilize `t_dynamic_mqtt_topic/1` testcase
This commit is contained in:
Andrew Mayorov 2023-10-10 23:00:20 +07:00 committed by GitHub
parent 0122574563 5fff2ffe45
commit 7bbb5250e7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
apps/emqx_bridge_kafka/test/emqx_bridge_kafka_impl_consumer_SUITE.erl
View File

@ -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),