fix: Corrupted lines in produce cmd with 'line' mode

birdayz · Sep 25, 2024 · d664341 · d664341
1 parent bfd8c16
commit d664341
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)