From 7f92c7bd55568d813bbe787478572a6f40fc0780 Mon Sep 17 00:00:00 2001 From: huyanping Date: Tue, 8 Nov 2016 12:21:46 +0800 Subject: [PATCH 1/2] throw exception when the connection is error. --- core/src/main/scala/kafka/network/BlockingChannel.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/network/BlockingChannel.scala b/core/src/main/scala/kafka/network/BlockingChannel.scala index 0f10577f8110..0026974fa373 100644 --- a/core/src/main/scala/kafka/network/BlockingChannel.scala +++ b/core/src/main/scala/kafka/network/BlockingChannel.scala @@ -82,7 +82,10 @@ class BlockingChannel( val host: String, connectTimeoutMs)) } catch { - case _: Throwable => disconnect() + case _: Throwable => { + disconnect() + throw _ + } } } } From 18d9456b874eac56b38c46b33dd742246081fba5 Mon Sep 17 00:00:00 2001 From: huyanping Date: Tue, 8 Nov 2016 17:32:02 +0800 Subject: [PATCH 2/2] fix syntax error --- core/src/main/scala/kafka/network/BlockingChannel.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/network/BlockingChannel.scala b/core/src/main/scala/kafka/network/BlockingChannel.scala index 0026974fa373..34935510e31e 100644 --- a/core/src/main/scala/kafka/network/BlockingChannel.scala +++ b/core/src/main/scala/kafka/network/BlockingChannel.scala @@ -82,9 +82,9 @@ class BlockingChannel( val host: String, connectTimeoutMs)) } catch { - case _: Throwable => { + case e: Throwable => { disconnect() - throw _ + throw e } } }