root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

kafka-1228; Socket Leak on ReplicaFetcherThread; patched by Ahmy Yulrizka; reviewed by Jun Rao

This commit is contained in:
Ahmy Yulrizka 2014-01-30 10:14:53 -08:00 committed by Jun Rao
parent 9c1d8e35c5
commit 2b0c6a7d7b
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/src/main/scala/kafka/consumer/SimpleConsumer.scala
View File

@ -72,19 +72,18 @@ class SimpleConsumer(val host: String,
blockingChannel.send(request) blockingChannel.send(request)
response = blockingChannel.receive() response = blockingChannel.receive()
} catch { } catch {
case e : java.io.IOException => case e : Throwable =>
info("Reconnect due to socket error: %s".format(e.getMessage)) warn("Reconnect due to socket error: %s".format(e.getMessage))
// retry once // retry once
try { try {
reconnect() reconnect()
blockingChannel.send(request) blockingChannel.send(request)
response = blockingChannel.receive() response = blockingChannel.receive()
} catch { } catch {
case ioe: java.io.IOException => case e: Throwable =>
disconnect() disconnect()
throw ioe throw e
} }
case e: Throwable => throw e
} }
response response
} }