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)