Skip to content

Commit d8f8073

Browse files
committed
pretty-print only if --pretty is passed
1 parent e2f4052 commit d8f8073

File tree

1 file changed

+11
-4
lines changed

1 file changed

+11
-4
lines changed

cmd/kaf/consume.go

+11-4
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,15 @@ import (
99
"github.com/spf13/cobra"
1010
)
1111

12-
var offsetFlag string
12+
var (
13+
offsetFlag string
14+
prettyPrint bool
15+
)
1316

1417
func init() {
1518
rootCmd.AddCommand(consumeCmd)
1619
consumeCmd.Flags().StringVar(&offsetFlag, "offset", "oldest", "Offset to start consuming. Possible values: oldest, newest. Default: newest")
20+
consumeCmd.Flags().BoolVar(&prettyPrint, "pretty", false, "Pretty print output if possible, e.g. for JSON.")
1721
}
1822

1923
var consumeCmd = &cobra.Command{
@@ -65,9 +69,12 @@ var consumeCmd = &cobra.Command{
6569
for msg := range pc.Messages() {
6670

6771
dataToDisplay := msg.Value
68-
formatted, err := prettyjson.Format(msg.Value)
69-
if err == nil {
70-
dataToDisplay = formatted
72+
73+
if prettyPrint {
74+
formatted, err := prettyjson.Format(msg.Value)
75+
if err == nil {
76+
dataToDisplay = formatted
77+
}
7178
}
7279

7380
if msg.Key != nil && len(msg.Key) > 0 {

0 commit comments

Comments
 (0)