Merge pull request #516 from zendesk/dasch/return-early-when-stopped

Shut down the consumer more quickly

Author: dasch

lib/kafka/consumer.rb

@@ -433,6 +433,9 @@ def join_group
     end
 
     def fetch_batches(min_bytes:, max_bytes:, max_wait_time:, automatically_mark_as_processed:)
+      # Return early if the consumer has been stopped.
+      return [] if !@running
+
       join_group unless @group.member?
 
       subscribed_partitions = @group.subscribed_partitions