diff --git a/plugins/outputs/opentsdb/opentsdb.go b/plugins/outputs/opentsdb/opentsdb.go index a4066e1d2..033bb69c2 100644 --- a/plugins/outputs/opentsdb/opentsdb.go +++ b/plugins/outputs/opentsdb/opentsdb.go @@ -89,7 +89,6 @@ func (o *OpenTSDB) Write(metrics []telegraf.Metric) error { return fmt.Errorf("Error in parsing host url: %s", err.Error()) } - if u.Scheme == "" || u.Scheme == "tcp" { return o.WriteTelnet(metrics, u) } else if u.Scheme == "http" { diff --git a/plugins/outputs/opentsdb/opentsdb_test.go b/plugins/outputs/opentsdb/opentsdb_test.go index 334a8566b..dfac45e7e 100644 --- a/plugins/outputs/opentsdb/opentsdb_test.go +++ b/plugins/outputs/opentsdb/opentsdb_test.go @@ -102,9 +102,9 @@ func BenchmarkHttpSend(b *testing.B) { } o := &OpenTSDB{ - Host: ts.URL, - Port: port, - Prefix: "", + Host: ts.URL, + Port: port, + Prefix: "", HttpBatchSize: BatchSize, }