trivial fix to use foreach instead of map

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1402731 13f79535-47bb-0310-9956-ffa450edef68
12 years ago · 4f529c7444
1 changed files with 1 additions and 1 deletions
--- a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
+++ b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
@ -248,7 +248,7 @@ class DefaultEventHandler[K,V](config: ProducerConfig,
				@@ -248,7 +248,7 @@ class DefaultEventHandler[K,V](config: ProducerConfig,
      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 =>