diff --git a/mdata/notifierKafka/notifierKafka.go b/mdata/notifierKafka/notifierKafka.go
index 193362ccae..8562aa8600 100644
--- a/mdata/notifierKafka/notifierKafka.go
+++ b/mdata/notifierKafka/notifierKafka.go
@@ -30,8 +30,8 @@ type NotifierKafka struct {
 }
 
 func NewNotifierKafka(instance string, metrics mdata.Metrics, stats met.Backend) *NotifierKafka {
-	messagesPublished = stats.NewCount("cluster.messages-published")
-	messagesSize = stats.NewMeter("cluster.message_size", 0)
+	messagesPublished = stats.NewCount("notifier.kafka.messages-published")
+	messagesSize = stats.NewMeter("notifier.kafka.message_size", 0)
 
 	client, err := sarama.NewClient(Brokers, Config)
 	if err != nil {
diff --git a/mdata/notifierNsq/notifierNsq.go b/mdata/notifierNsq/notifierNsq.go
index 9efe587cb9..04257c8a29 100644
--- a/mdata/notifierNsq/notifierNsq.go
+++ b/mdata/notifierNsq/notifierNsq.go
@@ -27,8 +27,8 @@ type NotifierNSQ struct {
 }
 
 func NewNSQ(instance string, metrics mdata.Metrics, stats met.Backend) *NotifierNSQ {
-	messagesPublished = stats.NewCount("cluster.messages-published")
-	messagesSize = stats.NewMeter("cluster.message_size", 0)
+	messagesPublished = stats.NewCount("notifier.nsq.messages-published")
+	messagesSize = stats.NewMeter("notifier.nsq.message_size", 0)
 	// producers
 	hostPool = hostpool.NewEpsilonGreedy(NsqdAdds, 0, &hostpool.LinearEpsilonValueCalculator{})
 	producers = make(map[string]*nsq.Producer)