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

Merge pull request #1930 from mariusbld/mariusbld/fix-kafka-logs

Browse Source 
Enable kafka logs when using kafka storage driver
This commit is contained in:
David Ashpole 2018-04-18 08:44:18 -07:00 committed by GitHub
commit 26fc1eb689
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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 {