Merge pull request #817 from abicky/disconnect-after-leaving

Disconnect after leaving the group

Author: dasch

lib/kafka/consumer.rb

@@ -125,7 +125,6 @@ def subscribe(topic_or_regex, default_offset: nil, start_from_beginning: true, m
     def stop
       @running = false
       @fetcher.stop
-      @cluster.disconnect
     end
 
     # Pause processing of a specific topic partition.
@@ -443,6 +442,7 @@ def consumer_loop
       # important that members explicitly tell Kafka when they're leaving.
       make_final_offsets_commit!
       @group.leave rescue nil
+      @cluster.disconnect
       @running = false
       @logger.pop_tags
     end