diff --git a/consumer/influx_stat.go b/consumer/influx_stat.go
index 5b33c85..f6d58f6 100644
--- a/consumer/influx_stat.go
+++ b/consumer/influx_stat.go
@@ -7,6 +7,8 @@ import (
 	"github.com/influxdata/influxdb/client/v2"
 	"time"
 	"strconv"
+	"runtime/debug"
+	"github.com/Sirupsen/logrus"
 )
 
 var (
@@ -45,6 +47,7 @@ func (m *influxMetric) StartLogging() {
 
 	defer func() {
 		if err := recover(); err != nil {
+			logrus.Errorf("ERR:%s",debug.Stack())
 			m.handler.NotifyError(err.(error))
 		}
 	}()