[ 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