From e3e7acbcde911e90646fd157dac268791785360e Mon Sep 17 00:00:00 2001
From: DDDHuang <44492639+DDDHuang@users.noreply.github.com>
Date: Thu, 28 Apr 2022 15:23:30 +0800
Subject: [PATCH] fix: remove match topic in mqtt bridge

---
 .../src/mqtt/emqx_connector_mqtt_mod.erl      | 23 +++----------------
 1 file changed, 3 insertions(+), 20 deletions(-)

diff --git a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_mod.erl b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_mod.erl
index 2f4f61043..7c3c66931 100644
--- a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_mod.erl
+++ b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_mod.erl
@@ -216,31 +216,14 @@ sub_remote_topics(ClientPid, #{remote_topic := FromTopic, remote_qos := QoS}) ->
 process_config(Config) ->
     maps:without([conn_type, address, receive_mountpoint, subscriptions, name], Config).
 
-maybe_publish_to_local_broker(
-    #{topic := Topic} = Msg,
-    #{remote_topic := SubTopic} = Vars,
-    Props
-) ->
+maybe_publish_to_local_broker(Msg, Vars, Props) ->
     case maps:get(local_topic, Vars, undefined) of
         undefined ->
             %% local topic is not set, discard it
             ok;
         _ ->
-            case emqx_topic:match(Topic, SubTopic) of
-                true ->
-                    _ = emqx_broker:publish(
-                        emqx_connector_mqtt_msg:to_broker_msg(Msg, Vars, Props)
-                    ),
-                    ok;
-                false ->
-                    ?SLOG(warning, #{
-                        msg => "discard_message_as_topic_not_matched",
-                        message => Msg,
-                        subscribed => SubTopic,
-                        got_topic => Topic
-                    })
-            end
-    end.
+            _ = emqx_broker:publish(emqx_connector_mqtt_msg:to_broker_msg(Msg, Vars, Props))
+end.
 
 format_msg_received(
     #{