diff --git a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl index b81735f46..16b039ba5 100644 --- a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl +++ b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl @@ -64,6 +64,8 @@ -define(pulsar_client_id, pulsar_client_id). -define(pulsar_producers, pulsar_producers). +-define(HEALTH_CHECK_RETRY_TIMEOUT, 4_000). + %%------------------------------------------------------------------------------------- %% `emqx_resource' API %%------------------------------------------------------------------------------------- @@ -440,9 +442,18 @@ render(Message, Template) -> emqx_placeholder:proc_tmpl(Template, Message, Opts). get_producer_status(Producers) -> + do_get_producer_status(Producers, 0). + +do_get_producer_status(_Producers, TimeSpent) when TimeSpent > ?HEALTH_CHECK_RETRY_TIMEOUT -> + connecting; +do_get_producer_status(Producers, TimeSpent) -> case pulsar_producers:all_connected(Producers) of - true -> connected; - false -> connecting + true -> + connected; + false -> + Sleep = 200, + timer:sleep(Sleep), + do_get_producer_status(Producers, TimeSpent + Sleep) end. partition_strategy(key_dispatch) -> first_key_dispatch; diff --git a/changes/ee/feat-11024.en.md b/changes/ee/feat-11024.en.md new file mode 100644 index 000000000..b34b88575 --- /dev/null +++ b/changes/ee/feat-11024.en.md @@ -0,0 +1 @@ +Added a small improvement to reduce the chance of seeing the `connecting` state when creating/updating a Pulsar Producer bridge.