[
https://issues.apache.org/jira/browse/KAFKA-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9600:
----------------------------------
Assignee: Boyang Chen
> EndTxn handler should check strict epoch equality
> -------------------------------------------------
>
> Key: KAFKA-9600
> URL: https://issues.apache.org/jira/browse/KAFKA-9600
> Project: Kafka
> Issue Type: Bug
> Reporter: Jason Gustafson
> Assignee: Boyang Chen
> Priority: Major
>
> The EndTxn path in TransactionCoordinator is shared between direct calls to
> EndTxn from the client and internal transaction abort logic. To support the
> latter, the code is written to allow an epoch bump. However, if the client
> bumps the epoch unexpectedly (e.g. due to a buggy implementation), then the
> internal invariants are violated which results in a hanging transaction.
> Specifically, the transaction is left in a pending state because the epoch
> following append to the log does not match what we expect.
> To fix this, we should ensure that an EndTxn from the client checks for
> strict epoch equality.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
