[ https://issues.apache.org/jira/browse/KAFKA-116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13090490#comment-13090490 ]
Neha Narkhede commented on KAFKA-116: ------------------------------------- thanks for pointing that out. I checked it in now. > 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 > 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