Issue 823 > Use max_wait_time while sleeping in fetch_batches

Author: elena

.gitignore

@@ -8,6 +8,7 @@
 /spec/reports/
 /tmp/
 .env
+.idea/
 *.log
 *.swp
 .byebug_history

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