kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1215027 - /incubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducer.scala
Date Fri, 16 Dec 2011 02:21:02 GMT
Author: junrao
Date: Fri Dec 16 02:21:02 2011
New Revision: 1215027

URL: http://svn.apache.org/viewvc?rev=1215027&view=rev
Log:
SyncProducer connect may return failed connection on reconnect; patched by Jun Rao; reviewed
by Neha Narkhede; KAFKA-226

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducer.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducer.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducer.scala?rev=1215027&r1=1215026&r2=1215027&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducer.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducer.scala Fri Dec 16
02:21:02 2011
@@ -155,7 +155,6 @@ class SyncProducer(val config: SyncProdu
   }
     
   private def connect(): SocketChannel = {
-    var channel: SocketChannel = null
     var connectBackoffMs = 1
     val beginTimeMs = SystemTime.milliseconds
     while(channel == null && !shutdown) {



Mime
View raw message