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

feat: add stop after render and after render trace to kafka action

This commit is contained in:
Kjell Winblad 2024-04-23 12:16:18 +02:00
parent b02ed4e6ec
commit 32c27f1711
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -319,6 +319,9 @@ on_query(
emqx_bridge_kafka_impl_producer_sync_query, emqx_bridge_kafka_impl_producer_sync_query,
#{headers_config => KafkaHeaders, instance_id => InstId} #{headers_config => KafkaHeaders, instance_id => InstId}
), ),
emqx_trace:rendered_action_template(MessageTag, #{
message => KafkaMessage, send_type => sync
}),
do_send_msg(sync, KafkaMessage, Producers, SyncTimeout) do_send_msg(sync, KafkaMessage, Producers, SyncTimeout)
catch catch
throw:{bad_kafka_header, _} = Error -> throw:{bad_kafka_header, _} = Error ->
@ -376,6 +379,9 @@ on_query_async(
emqx_bridge_kafka_impl_producer_async_query, emqx_bridge_kafka_impl_producer_async_query,
#{headers_config => KafkaHeaders, instance_id => InstId} #{headers_config => KafkaHeaders, instance_id => InstId}
), ),
emqx_trace:rendered_action_template(MessageTag, #{
message => KafkaMessage, send_type => async
}),
do_send_msg(async, KafkaMessage, Producers, AsyncReplyFn) do_send_msg(async, KafkaMessage, Producers, AsyncReplyFn)
catch catch
error:{invalid_partition_count, _Count, _Partitioner} -> error:{invalid_partition_count, _Count, _Partitioner} ->