Browse Source

fix(kafka producer action): set query timeout using non-conventional parameter schema

Thales Macedo Garitezi 1 năm trước cách đây
mục cha
commit
acec0d25e5

+ 6 - 0
apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl

@@ -14,6 +14,7 @@
 -export([
 -export([
     resource_type/0,
     resource_type/0,
     query_mode/1,
     query_mode/1,
+    query_opts/1,
     callback_mode/0,
     callback_mode/0,
     on_start/2,
     on_start/2,
     on_stop/2,
     on_stop/2,
@@ -45,6 +46,11 @@ query_mode(#{parameters := #{query_mode := sync}}) ->
 query_mode(_) ->
 query_mode(_) ->
     simple_async_internal_buffer.
     simple_async_internal_buffer.
 
 
+query_opts(#{parameters := #{query_mode := sync, sync_query_timeout := Timeout}}) ->
+    #{timeout => Timeout};
+query_opts(_) ->
+    #{}.
+
 callback_mode() -> async_if_possible.
 callback_mode() -> async_if_possible.
 
 
 check_config(Key, Config) when is_map_key(Key, Config) ->
 check_config(Key, Config) when is_map_key(Key, Config) ->