diff --git a/apps/emqx_rule_engine/src/emqx_rule_events.erl b/apps/emqx_rule_engine/src/emqx_rule_events.erl index 3070c054e..9aa7d0aa0 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_events.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_events.erl @@ -307,6 +307,8 @@ eventmsg_disconnected( ConnInfo = #{ peername := PeerName, sockname := SockName, + proto_name := ProtoName, + proto_ver := ProtoVer, disconnected_at := DisconnectedAt }, Reason @@ -319,6 +321,8 @@ eventmsg_disconnected( username => Username, peername => ntoa(PeerName), sockname => ntoa(SockName), + proto_name => ProtoName, + proto_ver => ProtoVer, disconn_props => printable_maps(maps:get(disconn_props, ConnInfo, #{})), disconnected_at => DisconnectedAt } @@ -844,6 +848,8 @@ columns_with_exam('client.disconnected') -> {<<"username">>, <<"u_emqx">>}, {<<"peername">>, <<"192.168.0.10:56431">>}, {<<"sockname">>, <<"0.0.0.0:1883">>}, + {<<"proto_name">>, <<"MQTT">>}, + {<<"proto_ver">>, 5}, columns_example_props(disconn_props), {<<"disconnected_at">>, erlang:system_time(millisecond)}, {<<"timestamp">>, erlang:system_time(millisecond)},