[jira] [Updated] (KAFKA-1865) Add a flush() call to the new producer API

["Jay Kreps (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jay Kreps updated KAFKA-1865:
-----------------------------
    Summary: Add a flush() call to the new producer API  (was: Investigate adding a flush() call to new producer API)

> Add a flush() call to the new producer API
> ------------------------------------------
>
>                 Key: KAFKA-1865
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1865
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Jay Kreps
>            Assignee: Jay Kreps
>         Attachments: KAFKA-1865.patch
>
>
> The postconditions of this would be that any record enqueued prior to flush() would have completed being sent (either successfully or not).
> An open question is whether you can continue sending new records while this call is executing (on other threads).
> We should only do this if it doesn't add inefficiencies for people who don't use it.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)