kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1402731 - /incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
Date Sat, 27 Oct 2012 01:18:27 GMT
Author: junrao
Date: Sat Oct 27 01:18:27 2012
New Revision: 1402731

URL: http://svn.apache.org/viewvc?rev=1402731&view=rev
Log:
trivial fix to use foreach instead of map

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

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala?rev=1402731&r1=1402730&r2=1402731&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
(original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
Sat Oct 27 01:18:27 2012
@@ -248,7 +248,7 @@ class DefaultEventHandler[K,V](config: P
       val topicAndPartition = e._1
       val produceData = e._2
       val messages = new ListBuffer[Message]
-      produceData.map(p => messages.appendAll(p.getData))
+      produceData.foreach(p => messages.appendAll(p.getData))
       ( topicAndPartition,
         config.compressionCodec match {
           case NoCompressionCodec =>



Mime
View raw message