diff --git a/features/stats.go b/features/stats.go index aed4f60..2cc5634 100644 --- a/features/stats.go +++ b/features/stats.go @@ -87,7 +87,7 @@ func (s *Stats) FromConfig(config viper.Viper) { if config.Sub("influxdb2") != nil { influx := config.Sub("influxdb2") s.influxdb2 = influxdb2.NewClient(influx.GetString("url"), influx.GetString("token")) - s.writeAPI2 = s.influxdb1.WriteAPIBlocking(influx.GetString("org"), influx.GetString("bucket")) + s.writeAPI2 = s.influxdb2.WriteAPIBlocking(influx.GetString("org"), influx.GetString("bucket")) s.writeAPI2.EnableBatching() s.Log.WithFields(log.Fields{"startup": true, "influxdb": "enabled"}).Info("Sending data to InfluxDB 2.x") }