diff --git a/pkg/mqtt/codec/v5/pubrel.go b/pkg/mqtt/codec/v5/pubrel.go index e016e0b..7e07acf 100644 --- a/pkg/mqtt/codec/v5/pubrel.go +++ b/pkg/mqtt/codec/v5/pubrel.go @@ -66,6 +66,8 @@ func (p *PubrelPacket) Unpack(b io.Reader) (err error) { if err != nil { return err } + } + if p.RemainingLength > 3 { err = p.PubrelProperties.Unpack(b) if err != nil { return err