Merge pull request elastic#1814 from adioss/resetFail

Backoff is not reset correctly after a correct ack is sent
leweafan · Jun 8, 2016 · 8527545 · 8527545
2 parents 870fba3 + d3ea523
commit 8527545
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/libbeat/outputs/mode/single.go b/libbeat/outputs/mode/single.go
@@ -132,6 +132,7 @@ func (s *SingleConnectionMode) publish(
 			goto sendFail
 		}
 
+		backoffCount = 0
 		debug("send completed")
 		outputs.SignalCompleted(signaler)
 		return nil
@@ -141,6 +142,7 @@ func (s *SingleConnectionMode) publish(
 		if resetFail {
 			debug("reset fails")
 			fails = 0
+			backoffCount = 0
 		}
 
 		if !guaranteed && (s.maxAttempts > 0 && fails == s.maxAttempts) {