diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-09-16 11:20:08 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-09-16 11:20:08 -0700 |
| commit | 5c6e3f457fb57472ccd6327902fcab0e288ecf86 (patch) | |
| tree | 04620110a60218aeb581b42c108d9482f484217c /weed/notification/kafka/kafka_queue.go | |
| parent | bc03233364484653228066d9ea27b6e78ba640f6 (diff) | |
| download | seaweedfs-5c6e3f457fb57472ccd6327902fcab0e288ecf86.tar.xz seaweedfs-5c6e3f457fb57472ccd6327902fcab0e288ecf86.zip | |
adjust log
Diffstat (limited to 'weed/notification/kafka/kafka_queue.go')
| -rw-r--r-- | weed/notification/kafka/kafka_queue.go | 4 |
1 files 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"), |