diff --git a/src/emqx_frame.erl b/src/emqx_frame.erl index 82db0acf5..59a195e33 100644 --- a/src/emqx_frame.erl +++ b/src/emqx_frame.erl @@ -331,7 +331,7 @@ parse_variable_byte_integer(<<0:1, Len:7, Rest/binary>>, Multiplier, Value) -> {Value + Len * Multiplier, Rest}. parse_topic_filters(subscribe, Bin) -> - [{Topic, #{rh => Rh, rap => Rap, nl => Nl, qos => QoS}} + [{Topic, #{rh => Rh, rap => Rap, nl => Nl, qos => QoS, rc => 0, subid => 0}} || <> <= Bin]; parse_topic_filters(unsubscribe, Bin) ->