diff --git a/consumer/consumer-handler.go b/consumer/consumer-handler.go
index 37a5412..48ba89a 100644
--- a/consumer/consumer-handler.go
+++ b/consumer/consumer-handler.go
@@ -74,7 +74,7 @@ func (ch *ConsumerHandlers) OnMessage(msg *kafka.Message) {
 		return
 	}
 
-	bp := oei.BatchPointsFor("metric")
+	bp := oei.BatchPointsFor(ch.GetConsumerName())
 	if nil == bp {
 		logging.Logger().Errorf("BatchPoints of InfluxDB is not valid")
 		return