add space for each message

telkomdev · Apr 29, 2019 · 1942514 · 1942514
1 parent 29909d8
commit 1942514
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/subscriber.go b/subscriber.go
@@ -93,7 +93,8 @@ func (handler *SubscriberHandler) ConsumeClaim(session sarama.ConsumerGroupSessi
 	// The `ConsumeClaim` itself is called within a goroutine, see:
 	// https://github.com/Shopify/sarama/blob/master/consumer_group.go#L27-L29
 	for message := range claim.Messages() {
-		log.Printf("\nMessage = %s\ntopic = %s", string(message.Value), message.Topic)
+		fmt.Println()
+		log.Printf("\nMessage = %s\nTopic = %s", string(message.Value), message.Topic)
 		session.MarkMessage(message, "")
 	}