diff --git a/pkg/broadcastwriter/broadcastwriter.go b/pkg/broadcastwriter/broadcastwriter.go index 1d3c3c5f15..2ee68944d1 100644 --- a/pkg/broadcastwriter/broadcastwriter.go +++ b/pkg/broadcastwriter/broadcastwriter.go @@ -51,7 +51,7 @@ func (w *BroadcastWriter) Write(p []byte) (n int, err error) { for { line, err := w.buf.ReadString('\n') if err != nil { - w.buf.Write([]byte(line)) + w.buf.WriteString(line) break } for stream, writers := range w.streams {