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

Merge pull request #13043 from kjellwinblad/kjell/kafka_incorrect_query_type/EMQX-12363 

fix(kafka trace): do not include query type in trace entry
This commit is contained in:
Kjell Winblad 2024-05-16 10:08:16 +02:00 committed by GitHub
parent 2eb1bb2b13 121084b2ff
commit 72b0c63ed2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl
View File

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