diff --git a/consumer/influx_stat.go b/consumer/influx_stat.go
index d736327..47aebbb 100644
--- a/consumer/influx_stat.go
+++ b/consumer/influx_stat.go
@@ -13,9 +13,10 @@ import (
 	"sync/atomic"
 )
 
-func init(){
+func init() {
 	influxmodels.EnableUintSupport()
 }
+
 type processorData struct {
 	Tempeture float64
 	FanSpeed  int
@@ -113,7 +114,7 @@ func (m *influxMetric) StartLogging() {
 		case <-ticker:
 			swapped := (*producer.OSMetricInfo)(atomic.SwapPointer(&osMetricPtr, nil))
 			copy(sendData, metricData)
-			go m.sendPoint(influxDbConn, sendData, swapped)
+			m.sendPoint(influxDbConn, sendData, swapped)
 		case <-m.handler.Done():
 			return
 		}
@@ -138,6 +139,8 @@ func (m *influxMetric) sendPoint(
 		Database:  "core",
 		Precision: "s",
 	})
+	batchPoint.SetWriteConsistency("consistency all")
+
 	if err != nil {
 		m.logger.Warn(err)
 		return