diff --git a/apps/emqx_bridge_mqtt/src/emqx_bridge_mqtt_connector.erl b/apps/emqx_bridge_mqtt/src/emqx_bridge_mqtt_connector.erl index 1bee2c92e..6f9465cb0 100644 --- a/apps/emqx_bridge_mqtt/src/emqx_bridge_mqtt_connector.erl +++ b/apps/emqx_bridge_mqtt/src/emqx_bridge_mqtt_connector.erl @@ -234,7 +234,7 @@ on_stop(ResourceId, State) -> undefined -> ok; TopicToHandlerIndex -> - emqx_topic_index:delete(TopicToHandlerIndex) + ets:delete(TopicToHandlerIndex) end, Allocated = emqx_resource:get_allocated_resources(ResourceId), ok = stop_helper(Allocated).