Don't raise IOError to the user

Author: dasch

lib/kafka/connection.rb

@@ -107,7 +107,7 @@ def send_request(request)
 
         response
       end
-    rescue SystemCallError, EOFError => e
+    rescue SystemCallError, EOFError, IOError => e
       close
 
       raise ConnectionError, "Connection error #{e.class}: #{e}"

lib/kafka/consumer.rb

@@ -365,6 +365,9 @@ def consumer_loop
           @logger.error "Leader not available; waiting 1s before retrying"
           @cluster.mark_as_stale!
           sleep 1
+        rescue ConnectionError => e
+          @logger.error "Connection error #{e.class}: #{e.message}"
+          @cluster.mark_as_stale!
         rescue SignalException => e
           @logger.warn "Received signal #{e.message}, shutting down"
           @running = false