don't show key if it's empty/unset

birdayz · Nov 19, 2018 · c0fc7e3 · c0fc7e3
1 parent 50383cd
commit c0fc7e3
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/cmd/kaf/consume.go b/cmd/kaf/consume.go
@@ -62,7 +62,11 @@ var consumeCmd = &cobra.Command{
 				}
 
 				for msg := range pc.Messages() {
-					fmt.Printf("%v %v\n", string(msg.Key), string(msg.Value))
+					if msg.Key != nil && len(msg.Key) > 0 {
+						fmt.Printf("%v %v\n", string(msg.Key), string(msg.Value))
+					} else {
+						fmt.Printf("%v\n", string(msg.Value))
+					}
 				}
 				wg.Done()
 			}(partition)