diff --git a/consumer/influx_stat.go b/consumer/influx_stat.go
index 2f7a743..7a16412 100644
--- a/consumer/influx_stat.go
+++ b/consumer/influx_stat.go
@@ -8,7 +8,6 @@ import (
 	"time"
 	"strconv"
 	"runtime/debug"
-	"github.com/sirupsen/logrus"
 )
 
 var (
@@ -47,7 +46,7 @@ func (m *influxMetric) StartLogging() {
 
 	defer func() {
 		if err := recover(); err != nil {
-			logrus.Errorf("ERR:%s",debug.Stack())
+			influxLogger.Errorf("ERR:%s", debug.Stack())
 			m.handler.NotifyError(err.(error))
 		}
 	}()