diff --git a/plugins/outputs/influxdb/influxdb.go b/plugins/outputs/influxdb/influxdb.go index 9dbf3ac4a..6b2e5d0ba 100644 --- a/plugins/outputs/influxdb/influxdb.go +++ b/plugins/outputs/influxdb/influxdb.go @@ -169,7 +169,7 @@ func (i *InfluxDB) Write(metrics []telegraf.Metric) error { } func (i *InfluxDB) udpClient(address *url.URL) (Client, error) { - serializer := &influx.Serializer{UintSupport: true} + serializer := &influx.Serializer{UintSupport: i.InfluxUintSupport} if err := serializer.Init(); err != nil { return nil, err } @@ -195,7 +195,7 @@ func (i *InfluxDB) httpClient(ctx context.Context, address *url.URL, proxy *url. return nil, err } - serializer := &influx.Serializer{UintSupport: true} + serializer := &influx.Serializer{UintSupport: i.InfluxUintSupport} if err := serializer.Init(); err != nil { return nil, err } diff --git a/plugins/outputs/influxdb/udp.go b/plugins/outputs/influxdb/udp.go index 48c8cab7e..1d4fcf804 100644 --- a/plugins/outputs/influxdb/udp.go +++ b/plugins/outputs/influxdb/udp.go @@ -46,7 +46,7 @@ func NewUDPClient(config UDPConfig) (*udpClient, error) { serializer := config.Serializer if serializer == nil { - serializer = &influx.Serializer{UintSupport: true} + serializer = &influx.Serializer{} if err := serializer.Init(); err != nil { return nil, err } diff --git a/plugins/outputs/influxdb_v2/influxdb_v2.go b/plugins/outputs/influxdb_v2/influxdb_v2.go index 1a46a586a..4a3b7d0cc 100644 --- a/plugins/outputs/influxdb_v2/influxdb_v2.go +++ b/plugins/outputs/influxdb_v2/influxdb_v2.go @@ -125,7 +125,7 @@ func (i *InfluxDB) getHTTPClient(address *url.URL, proxy *url.URL) (Client, erro return nil, err } - serializer := &influx.Serializer{UintSupport: true} + serializer := &influx.Serializer{UintSupport: i.UintSupport} if err := serializer.Init(); err != nil { return nil, err }