From 693d5dd39425ad409f49d42d7c43406e1d3bf1c9 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Mon, 29 Jul 2024 11:37:33 -0300 Subject: [PATCH] feat: attempt to automatically decode `payload` similar to key and message templates --- .../src/emqx_bridge_kafka_impl_producer.erl | 2 +- .../test/emqx_bridge_v2_kafka_producer_SUITE.erl | 7 +------ 2 files changed, 2 insertions(+), 7 deletions(-) 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 fb7fce63c..a8e1b56dd 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 @@ -469,7 +469,7 @@ render_topic({fixed, KafkaTopic}, _Message) -> KafkaTopic; render_topic({dynamic, Template}, Message) -> try - iolist_to_binary(emqx_template:render_strict(Template, Message)) + iolist_to_binary(emqx_template:render_strict(Template, {emqx_jsonish, Message})) catch error:_Errors -> throw(bad_topic) diff --git a/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_producer_SUITE.erl b/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_producer_SUITE.erl index 08b2723e7..baa5368cf 100644 --- a/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_producer_SUITE.erl +++ b/apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_producer_SUITE.erl @@ -967,12 +967,7 @@ t_dynamic_topics(Config) -> RuleTopic, [ {bridge_name, ActionName} - ], - #{ - sql => - <<"select *, json_decode(payload) as payload from \"", RuleTopic/binary, - "\" ">> - } + ] ), ?assertStatusAPI(Type, ActionName, <<"connected">>),