diff --git a/source/Log4Tc/Mbc.Log4Tc.Output.InfluxDb/InfluxDbOutput.cs b/source/Log4Tc/Mbc.Log4Tc.Output.InfluxDb/InfluxDbOutput.cs index 55c81f4..6b0454a 100644 --- a/source/Log4Tc/Mbc.Log4Tc.Output.InfluxDb/InfluxDbOutput.cs +++ b/source/Log4Tc/Mbc.Log4Tc.Output.InfluxDb/InfluxDbOutput.cs @@ -67,13 +67,16 @@ private void Initialize() { if (_client == null) { - char[] password = string.IsNullOrWhiteSpace(_settings.Password) ? null : _settings.Password.ToCharArray(); - _client = InfluxDBClientFactory.CreateV1(_settings.Url, _settings.Username, password, _settings.Database, _settings.RetentionPolicy); + _client = new InfluxDBClient(_settings.Url, _settings.Username, _settings.Password, _settings.Database, _settings.RetentionPolicy); } if (_writeApi == null) { - _writeApi = _client.GetWriteApi(new WriteOptions.Builder().BatchSize(_settings.WriteBatchSize).FlushInterval(_settings.WriteFlushIntervalMillis).Build()); + _writeApi = _client.GetWriteApi(new WriteOptions + { + BatchSize = _settings.WriteBatchSize, + FlushInterval = _settings.WriteFlushIntervalMillis + }); _writeApi.EventHandler += OnWriteApiEvent; } }