From 902b1d6ec5f7784248d182bbed87a215ee26eb7f Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Mon, 9 Oct 2023 10:51:37 -0300 Subject: [PATCH] fix(pulsar_producer): use `simple_async_internal_buffer` query mode for Pulsar Since it has internal buffering, it necessitates the same fix as Kafka producer. --- apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar.app.src | 2 +- .../emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl | 2 +- apps/emqx_resource/include/emqx_resource.hrl | 1 + 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar.app.src b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar.app.src index 16c9ce59f..b012874f8 100644 --- a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar.app.src +++ b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar.app.src @@ -1,6 +1,6 @@ {application, emqx_bridge_pulsar, [ {description, "EMQX Pulsar Bridge"}, - {vsn, "0.1.6"}, + {vsn, "0.1.7"}, {registered, []}, {applications, [ kernel, 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 2fc44e5ca..33ac83ee1 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 @@ -73,7 +73,7 @@ callback_mode() -> async_if_possible. query_mode(_Config) -> - simple_async. + simple_async_internal_buffer. -spec on_start(resource_id(), config()) -> {ok, state()}. on_start(InstanceId, Config) -> diff --git a/apps/emqx_resource/include/emqx_resource.hrl b/apps/emqx_resource/include/emqx_resource.hrl index fe4112c3d..61bc04de4 100644 --- a/apps/emqx_resource/include/emqx_resource.hrl +++ b/apps/emqx_resource/include/emqx_resource.hrl @@ -26,6 +26,7 @@ simple_sync | simple_async | simple_sync_internal_buffer + | simple_async_internal_buffer | sync | async | no_queries.