kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1397717 - /incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
Date Fri, 12 Oct 2012 20:28:14 GMT
Author: junrao
Date: Fri Oct 12 20:28:14 2012
New Revision: 1397717

URL: http://svn.apache.org/viewvc?rev=1397717&view=rev
Log:
Replication Data Loss in Mirror Maker Bouncing testcase; patched by Jun Rao; reviewed by Joel
Koshy, John Fung and Neha Narkhede; kafka-567

Modified:
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala?rev=1397717&r1=1397716&r2=1397717&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
(original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
Fri Oct 12 20:28:14 2012
@@ -93,6 +93,8 @@ class ProducerSendThread[K,V](val thread
           events = new ListBuffer[ProducerData[K,V]]
         }
     }
+    // send the last batch of events
+    tryToHandle(events)
     if(queue.size > 0)
       throw new IllegalQueueStateException("Invalid queue state! After queue shutdown, %d
remaining items in the queue"
         .format(queue.size))



Mime
View raw message