[ https://issues.apache.org/jira/browse/KAFKA-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027962#comment-16027962 ]
ASF GitHub Bot commented on KAFKA-5251: --------------------------------------- GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3161 KAFKA-5251: Producer should cancel unsent AddPartitions and Produce requests on abort You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5251 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3161.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3161 ---- commit 501a761326128172546b5235c3cdd4d1862a2de8 Author: Jason Gustafson <ja...@confluent.io> Date: 2017-05-26T16:36:18Z KAFKA-5251: Producer should cancel unsent Produce and AddPartitions requests on abort ---- > Producer should drop queued sends when transaction is aborted > ------------------------------------------------------------- > > Key: KAFKA-5251 > URL: https://issues.apache.org/jira/browse/KAFKA-5251 > Project: Kafka > Issue Type: Sub-task > Components: clients, core, producer > Reporter: Jason Gustafson > Assignee: Jason Gustafson > Priority: Blocker > Labels: exactly-once > Fix For: 0.11.0.0 > > > As an optimization, if a transaction is aborted, we can drop any records > which have not yet been sent to the brokers. However, to avoid the sequence > number getting out of sync, we need to continue sending any request which has > been sent at least once. -- This message was sent by Atlassian JIRA (v6.3.15#6346)