From 5c6e3f457fb57472ccd6327902fcab0e288ecf86 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 16 Sep 2018 11:20:08 -0700 Subject: [PATCH] adjust log --- weed/notification/kafka/kafka_queue.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/weed/notification/kafka/kafka_queue.go b/weed/notification/kafka/kafka_queue.go index 8eb41cf85..f0e353f93 100644 --- a/weed/notification/kafka/kafka_queue.go +++ b/weed/notification/kafka/kafka_queue.go @@ -22,8 +22,8 @@ func (k *KafkaQueue) GetName() string { } func (k *KafkaQueue) Initialize(configuration util.Configuration) (err error) { - glog.V(0).Infof("filer.msgqueue.kafka.hosts: %v\n", configuration.GetStringSlice("hosts")) - glog.V(0).Infof("filer.msgqueue.kafka.topic: %v\n", configuration.GetString("topic")) + glog.V(0).Infof("filer.notification.kafka.hosts: %v\n", configuration.GetStringSlice("hosts")) + glog.V(0).Infof("filer.notification.kafka.topic: %v\n", configuration.GetString("topic")) return k.initialize( configuration.GetStringSlice("hosts"), configuration.GetString("topic"),