chore(ft): tidy up the code according to the review

apps/emqx/src/emqx_channel.erl

@@ -1049,7 +1049,7 @@ handle_out(disconnect, {ReasonCode, ReasonName}, Channel) ->
     handle_out(disconnect, {ReasonCode, ReasonName, #{}}, Channel);
 handle_out(disconnect, {ReasonCode, ReasonName, Props}, Channel = ?IS_MQTT_V5) ->
     Packet = ?DISCONNECT_PACKET(ReasonCode, Props),
-    {ok, [?REPLY_OUTGOING(Packet), {close, ReasonName}], Channel};
+    {ok, [?REPLY_OUTGOING(Packet), ?REPLY_CLOSE(ReasonName)], Channel};
 handle_out(disconnect, {_ReasonCode, ReasonName, _Props}, Channel) ->
     {ok, {close, ReasonName}, Channel};
 handle_out(auth, {ReasonCode, Properties}, Channel) ->

apps/emqx_ft/src/emqx_ft_app.erl

@@ -22,7 +22,6 @@
 
 start(_StartType, _StartArgs) ->
     {ok, Sup} = emqx_ft_sup:start_link(),
-    ok = emqx_ft_async_reply:create_tables(),
     ok = emqx_ft_conf:load(),
     {ok, Sup}.
 

apps/emqx_ft/src/emqx_ft_async_reply.erl

@@ -62,8 +62,8 @@ create_tables() ->
         {read_concurrency, true},
         {write_concurrency, true}
     ],
-    _ = ets:new(?MON_TAB, EtsOptions),
+    ok = emqx_utils_ets:new(?MON_TAB, EtsOptions),
-    _ = ets:new(?PACKET_TAB, EtsOptions),
+    ok = emqx_utils_ets:new(?PACKET_TAB, EtsOptions),
     ok.
 
 -spec register(packet_id(), mon_ref(), timer_ref()) -> ok.

apps/emqx_ft/src/emqx_ft_sup.erl

@@ -28,6 +28,8 @@ start_link() ->
     supervisor:start_link({local, ?SERVER}, ?MODULE, []).
 
 init([]) ->
+    ok = emqx_ft_async_reply:create_tables(),
+
     SupFlags = #{
         strategy => one_for_one,
         intensity => 100,