Update .travis.yml build targets

logstash-plugins · Feb 11, 2019 · d06346e · d06346e
1 parent b9d852d
commit d06346e
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/lib/logstash/outputs/kafka.rb b/lib/logstash/outputs/kafka.rb
@@ -284,12 +284,11 @@ def retrying_send(batch)
       break if failures.empty?
 
       # Otherwise, retry with any failed transmissions
-      if remaining != nil && remaining < 0
-        logger.info("Sending batch to Kafka failed.", :batch_size => batch.size,:failures => failures.size)
-      else
+      if remaining.nil? || remaining >= 0
         delay = @retry_backoff_ms / 1000.0
         logger.info("Sending batch to Kafka failed. Will retry after a delay.", :batch_size => batch.size,
-                    :failures => failures.size, :sleep => delay)
+                                                                                :failures => failures.size,
+                                                                                :sleep => delay)
         batch = failures
         sleep(delay)
       end