diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl index 16bca153a..70091e7c2 100644 --- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl +++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl @@ -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