From 8685ef0ac8dd3bc7f1fdfdd0454eab470327e4d5 Mon Sep 17 00:00:00 2001 From: Aditya Auradkar Date: Tue, 28 Apr 2015 10:24:51 -0700 Subject: [PATCH] Fixing KAFKA-1886 --- core/src/main/scala/kafka/consumer/SimpleConsumer.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala index cbef84a..31a2639 100644 --- a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala +++ b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala @@ -17,6 +17,9 @@ package kafka.consumer + +import java.nio.channels.ClosedByInterruptException + import kafka.api._ import kafka.network._ import kafka.utils._ @@ -70,6 +73,8 @@ class SimpleConsumer(val host: String, blockingChannel.send(request) response = blockingChannel.receive() } catch { + case e : ClosedByInterruptException => + throw e case e : Throwable => info("Reconnect due to socket error: %s".format(e.toString)) // retry once -- 1.7.12.4