From d384893f9c739fb300db6069eeefd3c13fbefc8c Mon Sep 17 00:00:00 2001
From: Conor Mongey <conor@mongey.net>
Date: Fri, 8 Feb 2019 19:00:59 +0000
Subject: [PATCH] Log sarama information

---
 kafka/client.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/kafka/client.go b/kafka/client.go
index 1b160811..42b94a9b 100644
--- a/kafka/client.go
+++ b/kafka/client.go
@@ -4,6 +4,7 @@ import (
 	"errors"
 	"fmt"
 	"log"
+	"os"
 	"time"
 
 	"github.com/Shopify/sarama"
@@ -37,6 +38,7 @@ func NewClient(config *Config) (*Client, error) {
 	}
 
 	c, err := sarama.NewClient(bootstrapServers, kc)
+	sarama.Logger = log.New(os.Stdout, "[TRACE] [Sarama]", log.LstdFlags)
 	if err != nil {
 		log.Println("[ERROR] Error connecting to kafka")
 		return nil, err