Merge pull request #825 from ElenaHenderson/remove-hard-codes-sleep-consumer-fetch-batches

Issue 823 > Use max_wait_time while sleeping in fetch_batches

Author: dasch

lib/kafka/consumer.rb

@@ -546,7 +546,7 @@ def fetch_batches
 
       if !@fetcher.data?
         @logger.debug "No batches to process"
-        sleep 2
+        sleep(@fetcher.max_wait_time || 2)
         []
       else
         tag, message = @fetcher.poll

lib/kafka/fetcher.rb

@@ -4,7 +4,7 @@
 
 module Kafka
   class Fetcher
-    attr_reader :queue
+    attr_reader :queue, :max_wait_time
 
     def initialize(cluster:, logger:, instrumenter:, max_queue_size:, group:)
       @cluster = cluster