Merge pull request #456 from hoteltonight/jm-handle-replaced-coordinator

Handle the case where the coordinator is replaced with a new host

Author: dasch

lib/kafka/consumer_group.rb

@@ -48,6 +48,7 @@ def join
     rescue ConnectionError
       @logger.error "Connection error while trying to join group `#{@group_id}`; retrying..."
       sleep 1
+      @cluster.mark_as_stale!
       @coordinator = nil
       retry
     end