lib/kafka/fetcher.rb in ruby-kafka-0.7.10 vs lib/kafka/fetcher.rb in ruby-kafka-1.0.0

@@ -15,10 +15,13 @@
 
       @queue = Queue.new
       @commands = Queue.new
       @next_offsets = Hash.new { |h, k| h[k] = {} }
 
+      # We are only running when someone calls start.
+      @running = false
+
       # Long poll until at least this many bytes can be fetched.
       @min_bytes = 1
 
       # Long poll at most this number of seconds.
       @max_wait_time = 1
@@ -108,10 +111,10 @@
 
         send("handle_#{cmd}", *args)
       elsif @queue.size < @max_queue_size
         step
       else
-        @logger.warn "Reached max fetcher queue size (#{@max_queue_size}), sleeping 1s"
+        @logger.info "Reached max fetcher queue size (#{@max_queue_size}), sleeping 1s"
         sleep 1
       end
     ensure
       @logger.pop_tags
     end