lib/kafka/connection.rb in ruby-kafka-0.5.1 vs lib/kafka/connection.rb in ruby-kafka-0.5.2.beta1
- old
+ new
@@ -105,10 +105,10 @@
@last_request = Time.now
response
end
- rescue SystemCallError, EOFError => e
+ rescue SystemCallError, EOFError, IOError => e
close
raise ConnectionError, "Connection error #{e.class}: #{e}"
end