Since it has internal buffering, it necessitates the same fix as Kafka producer.
@@ -1,6 +1,6 @@
{application, emqx_bridge_pulsar, [
{description, "EMQX Pulsar Bridge"},
- {vsn, "0.1.6"},
+ {vsn, "0.1.7"},
{registered, []},
{applications, [
kernel,
@@ -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) ->
@@ -26,6 +26,7 @@
simple_sync
| simple_async
| simple_sync_internal_buffer
+ | simple_async_internal_buffer
| sync
| async
| no_queries.