[ 
https://issues.apache.org/jira/browse/KAFKA-353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13400682#comment-13400682
 ] 

Jun Rao commented on KAFKA-353:
-------------------------------

The race condition that Jay raised seems like a potential issue. However, it 
may be tricky to add the watcher before writing to the local log in the leader. 
This is because the watcher needs to know the end offset of messages in the 
leader's log. Another way to address the race condition is to still add 
messages to leader's log first, followed by adding the watcher. However, after 
the watcher is added, we can explicitly trigger a watcher check by calling 
ProducerRequestPurgatory.update.
                
> tie producer-side ack with high watermark and progress of replicas
> ------------------------------------------------------------------
>
>                 Key: KAFKA-353
>                 URL: https://issues.apache.org/jira/browse/KAFKA-353
>             Project: Kafka
>          Issue Type: Sub-task
>    Affects Versions: 0.8
>            Reporter: Jun Rao
>            Assignee: Joel Koshy
>         Attachments: kafka-353_v1.patch
>
>


--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to