You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Jun Rao (JIRA)" <ji...@apache.org> on 2011/09/13 03:31:10 UTC

[jira] [Updated] (KAFKA-116) AsyncProducer shutdown logic causes data loss

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

Jun Rao updated KAFKA-116:
--------------------------

       Resolution: Fixed
    Fix Version/s: 0.7
           Status: Resolved  (was: Patch Available)

> AsyncProducer shutdown logic causes data loss
> ---------------------------------------------
>
>                 Key: KAFKA-116
>                 URL: https://issues.apache.org/jira/browse/KAFKA-116
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.7
>            Reporter: Neha Narkhede
>             Fix For: 0.7
>
>         Attachments: KAFKA-116.patch
>
>
> The current shutdown logic of the AsyncProducer allows adding events to the queue, after adding the shutdown command to it. The ProducerSendThread drains all the data in the queue until it hits the shutdown command. Hence, all data added after the shutdown command is lost.

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira