|
|
@@ -320,7 +320,7 @@ on_query(
|
|
|
#{headers_config => KafkaHeaders, instance_id => InstId}
|
|
|
),
|
|
|
emqx_trace:rendered_action_template(MessageTag, #{
|
|
|
- message => KafkaMessage, send_type => sync
|
|
|
+ message => KafkaMessage
|
|
|
}),
|
|
|
do_send_msg(sync, KafkaMessage, Producers, SyncTimeout)
|
|
|
catch
|
|
|
@@ -380,7 +380,7 @@ on_query_async(
|
|
|
#{headers_config => KafkaHeaders, instance_id => InstId}
|
|
|
),
|
|
|
emqx_trace:rendered_action_template(MessageTag, #{
|
|
|
- message => KafkaMessage, send_type => async
|
|
|
+ message => KafkaMessage
|
|
|
}),
|
|
|
do_send_msg(async, KafkaMessage, Producers, AsyncReplyFn)
|
|
|
catch
|