diff --git a/plugins/outputs/graphite/graphite.go b/plugins/outputs/graphite/graphite.go index b4fe415a75b4b..6ee54aa2d1d1f 100644 --- a/plugins/outputs/graphite/graphite.go +++ b/plugins/outputs/graphite/graphite.go @@ -127,7 +127,10 @@ func (g *Graphite) Write(points []*client.Point) error { break } } - + // try to reconnect + if err != nil { + g.Connect() + } return err }