[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Attachment: KAFKA-955.v7.patch
Thanks for the comments, Neha, Jay.
Neha:
1. Done.
2. Incorporated
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Attachment: KAFKA-955.v5.patch
Thanks for the comments Neha.
1.1. Great point. The only concern is
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Attachment: KAFKA-955.v6.patch
After talking around with people I now proposed an approach similar
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Attachment: KAFKA-955.v4.patch
Thanks for the comments Jun.
30. Done.
31. After a second thought I
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Assignee: Guozhang Wang
After a leader change, messages sent with ack=0 are lost
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Attachment: KAFKA-955.v1.patch
After a leader change, messages sent with ack=0 are lost
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Status: Patch Available (was: Open)
Following the close-socket approach, I propose the following
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-955:
Attachment: KAFKA-955.v1.patch
Add one case for ack=0 in testSendWithDeadBroker, passed.