From d664341bb2ce0154a1f6cd66fbda79286800f50a Mon Sep 17 00:00:00 2001 From: Vladimir Burian Date: Wed, 25 Sep 2024 21:19:10 +0200 Subject: [PATCH] fix: Corrupted lines in produce cmd with 'line' mode --- cmd/kaf/produce.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/kaf/produce.go b/cmd/kaf/produce.go index 40897af..d07a92e 100644 --- a/cmd/kaf/produce.go +++ b/cmd/kaf/produce.go @@ -69,7 +69,7 @@ func readLines(reader io.Reader, out chan []byte) { } for scanner.Scan() { - out <- scanner.Bytes() + out <- bytes.Clone(scanner.Bytes()) } close(out)