Fix build for all OS after elastic#8424 (elastic#8717)

* Fix build for all OS after elastic#8424

* Apply PR comments

filebeat/reader/docker_json/docker_json.go

@@ -20,6 +20,7 @@ package docker_json
 import (
 	"bytes"
 	"encoding/json"
+	"runtime"
 	"time"
 
 	"github.com/elastic/beats/filebeat/reader"
@@ -42,6 +43,8 @@ type Reader struct {
 
 	// parse CRI flags
 	criflags bool
+
+	stripNewLine func(msg *reader.Message)
 }
 
 type logLine struct {
@@ -54,13 +57,21 @@ type logLine struct {
 
 // New creates a new reader renaming a field
 func New(r reader.Reader, stream string, partial bool, forceCRI bool, CRIFlags bool) *Reader {
-	return &Reader{
+	reader := Reader{
 		stream:   stream,
 		partial:  partial,
 		reader:   r,
 		forceCRI: forceCRI,
 		criflags: CRIFlags,
 	}
+
+	if runtime.GOOS == "windows" {
+		reader.stripNewLine = stripNewLineWin
+	} else {
+		reader.stripNewLine = stripNewLine
+	}
+
+	return &reader
 }
 
 // parseCRILog parses logs in CRI log format.
@@ -112,7 +123,7 @@ func (p *Reader) parseCRILog(message *reader.Message, msg *logLine) error {
 	// Remove \n ending for partial messages
 	message.Content = log[i]
 	if partial {
-		stripNewLine(message)
+		p.stripNewLine(message)
 	}
 
 	return nil
@@ -192,3 +203,16 @@ func (p *Reader) Next() (reader.Message, error) {
 		return message, err
 	}
 }
+
+func stripNewLine(msg *reader.Message) {
+	l := len(msg.Content)
+	if l > 0 && msg.Content[l-1] == '\n' {
+		msg.Content = msg.Content[:l-1]
+	}
+}
+
+func stripNewLineWin(msg *reader.Message) {
+	msg.Content = bytes.TrimRightFunc(msg.Content, func(r rune) bool {
+		return r == '\n' || r == '\r'
+	})
+}