[jira] [Created] (KAFKA-1496) Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument

["Guan Liao (JIRA)" <ji...@apache.org>]

Guan Liao created KAFKA-1496:
--------------------------------

             Summary: Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument 
                 Key: KAFKA-1496
                 URL: https://issues.apache.org/jira/browse/KAFKA-1496
             Project: Kafka
          Issue Type: Bug
          Components: producer 
    Affects Versions: 0.8.1
         Environment: Scala 2.10
            Reporter: Guan Liao
            Assignee: Jun Rao
            Priority: Minor


I am passing a Scala Stream to the producer as followed:

producer.send(events.toSeq:*)

The events was a Scala Stream of KeyedMessages. In sync mode, it will only send one message to Kafka while in async mode it was fine. I tracked down the issue and I'm attaching a fix for it.



--
This message was sent by Atlassian JIRA
(v6.2#6252)