From 9248d0f2dba32ea736534ca31662b7e1b8a35f7b Mon Sep 17 00:00:00 2001 From: adioss Date: Fri, 3 Jun 2016 19:05:12 +0200 Subject: [PATCH] Reset backoffCount after correct ACK received --- libbeat/outputs/mode/single.go | 1 + 1 file changed, 1 insertion(+) diff --git a/libbeat/outputs/mode/single.go b/libbeat/outputs/mode/single.go index 4ecf454d2104..8d2b2d8478d8 100644 --- a/libbeat/outputs/mode/single.go +++ b/libbeat/outputs/mode/single.go @@ -141,6 +141,7 @@ func (s *SingleConnectionMode) publish( if resetFail { debug("reset fails") fails = 0 + backoffCount = 0 } if !guaranteed && (s.maxAttempts > 0 && fails == s.maxAttempts) {