From 970f2e54ed49892bd5d98e286e973274d56d4709 Mon Sep 17 00:00:00 2001
From: Marius Buleandra <mbuleandra@gmail.com>
Date: Tue, 17 Apr 2018 18:04:18 -0400
Subject: [PATCH] Enable kafka logs

---
 storage/kafka/kafka.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/storage/kafka/kafka.go b/storage/kafka/kafka.go
index cd7f88cb..6f5f3639 100644
--- a/storage/kafka/kafka.go
+++ b/storage/kafka/kafka.go
@@ -20,6 +20,7 @@ import (
 	"encoding/json"
 	"flag"
 	"io/ioutil"
+	"log"
 	"os"
 	"strings"
 	"time"
@@ -34,6 +35,7 @@ import (
 
 func init() {
 	storage.RegisterStorageDriver("kafka", new)
+	kafka.Logger = log.New(os.Stderr, "[kafka]", log.LstdFlags)
 }
 
 var (
@@ -141,7 +143,7 @@ func newStorage(machineName string) (storage.StorageDriver, error) {
 	config.Producer.RequiredAcks = kafka.WaitForAll
 
 	brokerList := strings.Split(*brokers, ",")
-	glog.V(4).Infof("Kafka brokers:%q", brokers)
+	glog.V(4).Infof("Kafka brokers:%q", *brokers)
 
 	producer, err := kafka.NewAsyncProducer(brokerList, config)
 	if err != nil {