Improve message formating

mouminoux · Jul 26, 2018 · 5392885 · 5392885
1 parent 04d0b22
commit 5392885
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/kafkacli.go b/kafkacli.go
@@ -78,13 +78,17 @@ func main() {
 }
 
 func displayMessage(msg *sarama.ConsumerMessage) {
-	fmt.Printf("[%s]----------------\n", msg.Timestamp)
-	fmt.Printf("Headers on %s/%d:", msg.Topic, msg.Partition)
+	fmt.Printf("[%s] %s/%d----------------\n", msg.Timestamp, msg.Topic, msg.Partition)
+	fmt.Printf("Headers:")
 	for _, header := range msg.Headers {
 		fmt.Printf(" %s=%s", header.Key, header.Value)
 	}
 	fmt.Printf("\n")
-	fmt.Printf("Message on %s/%d: [%s]%s\n", msg.Topic, msg.Partition, msg.Key, msg.Value)
+	fmt.Printf("Message")
+	if msg.Key != nil {
+		fmt.Printf("[%s]%", msg.Key)
+	}
+	fmt.Printf(": %s\n", msg.Value)
 }
 
 func die(err error) {