diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.erl b/apps/emqx_rule_engine/src/emqx_rule_engine.erl index d92931d77..dd4b52d44 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_engine.erl @@ -226,7 +226,7 @@ get_rules_ordered_by_ts() -> get_rules_for_topic(Topic) -> [ emqx_rule_index:get_record(M, ?RULE_TOPIC_INDEX) - || M <- emqx_rule_index:matches(Topic, ?RULE_TOPIC_INDEX) + || M <- emqx_rule_index:matches(Topic, ?RULE_TOPIC_INDEX, [unique]) ]. -spec get_rules_with_same_event(Topic :: binary()) -> [rule()].