lib/kafka/fetcher.rb in ruby-kafka-0.6.0.beta2 vs lib/kafka/fetcher.rb in ruby-kafka-0.6.0.beta3

@@ -73,10 +73,14 @@
     end
 
     private
 
     def loop
+      @instrumenter.instrument("loop.fetcher", {
+        queue_size: @queue.size,
+      })
+
       if !@commands.empty?
         cmd, args = @commands.deq
 
         @logger.debug "Handling fetcher command: #{cmd}"
 
@@ -97,9 +101,10 @@
       @max_wait_time = max_wait_time
     end
 
     def handle_reset
       @next_offsets.clear
+      @queue.clear
     end
 
     def handle_stop(*)
       @running = false