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

fix: fixes due to comments from @zmstone

This commit is contained in:
Kjell Winblad 2023-06-08 16:47:02 +02:00
parent cb3a5fdbd4
commit 1c7834e056
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl
View File

@ -305,7 +305,7 @@ fields(producer_kafka_opts) ->
)}, )},
{sync_query_timeout, {sync_query_timeout,
mk( mk(
emqx_schema:duration_ms(), emqx_schema:timeout_duration_ms(),
#{ #{
default => <<"5s">>, default => <<"5s">>,
desc => ?DESC(sync_query_timeout) desc => ?DESC(sync_query_timeout)

3
apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl
View File

@ -70,9 +70,8 @@
callback_mode() -> async_if_possible. callback_mode() -> async_if_possible.
%% consumer bridges don't need resource workers
query_mode(_Config) -> query_mode(_Config) ->
no_queries. simple_async.
-spec on_start(resource_id(), config()) -> {ok, state()}. -spec on_start(resource_id(), config()) -> {ok, state()}.
on_start(InstanceId, Config) -> on_start(InstanceId, Config) ->