prometheus/cadvisor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Enable kafka logs

Browse Source
This commit is contained in:
Marius Buleandra 2018-04-17 18:04:18 -04:00
parent 8578a54b8b
commit 970f2e54ed
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
storage/kafka/kafka.go
View File

@ -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 {