From 844b2b6a64016b316a0addc641a6a30c76c7da96 Mon Sep 17 00:00:00 2001
From: crusader <crusader@loafle.com>
Date: Wed, 4 Jul 2018 20:14:25 +0900
Subject: [PATCH] ing

---
 consumer/consumer-handler.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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