Merge pull request #16 from fgrosse/fix-consume-raw-output

fgrosse · web-flow · commit 69bc4e8adbd8 · 2023-07-20T16:54:10.000+02:00
Fix bug in kafkactl consume when --output is set to "raw"
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -5,6 +5,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
+- Fix `kafkactl consume` when outputing raw messages
 - Fix bug in `kafkactl get topics` that caused wrong partition IDs in JSON output
 - Add `--with-config` flag to `kafkactl create topic`
 
diff --git a/cmd/consume/consume.go b/cmd/consume/consume.go
@@ -119,7 +119,10 @@ func (cmd *command) consume(ctx context.Context, topic string, partitions []int,
 	for msg := range messages {
 		if outputEncoding == "raw" {
 			_, err := os.Stdout.Write(msg.Value)
-			return err
+			if err != nil {
+				return err
+			}
+			continue
 		}
 
 		decoded, err := dec.Decode(msg)
