diff --git a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
index fac64aa..5896f19 100644
--- a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
+++ b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
@@ -80,9 +80,9 @@ class SimpleConsumer(val host: String,
             blockingChannel.send(request)
             response = blockingChannel.receive()
           } catch {
-            case ioe: java.io.IOException =>
+            case e: Throwable =>
               disconnect()
-              throw ioe
+              throw e
           }
         case e: Throwable => throw e
       }