diff --git a/emitter.go b/emitter.go index b8dc70f..2b92553 100644 --- a/emitter.go +++ b/emitter.go @@ -58,16 +58,21 @@ func CopyMulty(src io.Reader, writers ...io.Writer) (err error) { for { nr, er := src.Read(buf) + _maxN := nr + if nr > 500 { + _maxN = 500 + } if nr > 0 && len(buf) > nr { payload := buf[:nr] meta := payloadMeta(payload) - requestID := string(meta[1]) - - _maxN := nr - if nr > 500 { - _maxN = 500 + if len(meta) < 3 { + if Settings.debug { + Debug("[EMITTER] Found malformed record", string(payload[0:_maxN]), nr, "from:", src) + } + continue } + requestID := string(meta[1]) if Settings.debug { Debug("[EMITTER] input:", string(payload[0:_maxN]), nr, "from:", src)