diff --git a/src/emqx_broker.erl b/src/emqx_broker.erl index 380e16c42..5f3e63059 100644 --- a/src/emqx_broker.erl +++ b/src/emqx_broker.erl @@ -272,7 +272,8 @@ subscriber_down(SubPid) -> I -> true = ets:delete_object(?SUBSCRIBER, {Topic, {shared, I}}), true = ets:delete_object(?SUBSCRIBER, {{shared, Topic, I}, SubPid}), ok = cast(pick({Topic, I}), {unsubscribed, Topic, I}) - end; + end, + ets:delete(?SUBOPTION, Sub); [] -> ok end end, ets:lookup(?SUBSCRIPTION, SubPid)),