From 1c7834e0565bd224b489669df682b593ede98590 Mon Sep 17 00:00:00 2001 From: Kjell Winblad Date: Thu, 8 Jun 2023 16:47:02 +0200 Subject: [PATCH] fix: fixes due to comments from @zmstone --- apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl | 2 +- .../src/emqx_bridge_pulsar_impl_producer.erl | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl index 5f0dcee72..31307fd16 100644 --- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl +++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl @@ -305,7 +305,7 @@ fields(producer_kafka_opts) -> )}, {sync_query_timeout, mk( - emqx_schema:duration_ms(), + emqx_schema:timeout_duration_ms(), #{ default => <<"5s">>, desc => ?DESC(sync_query_timeout) 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 1d93ffd0d..0dcf1bf66 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 @@ -70,9 +70,8 @@ callback_mode() -> async_if_possible. -%% consumer bridges don't need resource workers query_mode(_Config) -> - no_queries. + simple_async. -spec on_start(resource_id(), config()) -> {ok, state()}. on_start(InstanceId, Config) ->