[
https://issues.apache.org/jira/browse/KAFKA-8351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-8351.
------------------------------------
Resolution: Fixed
Fix Version/s: 2.2.2
2.3.0
> Log cleaner must handle transactions spanning multiple segments
> ---------------------------------------------------------------
>
> Key: KAFKA-8351
> URL: https://issues.apache.org/jira/browse/KAFKA-8351
> Project: Kafka
> Issue Type: Bug
> Components: log cleaner
> Reporter: Jason Gustafson
> Assignee: Jason Gustafson
> Priority: Major
> Fix For: 2.3.0, 2.2.2
>
>
> When cleaning transactions, we have to do some bookkeeping to keep track of
> which transactions still have data left around. As long as there is still
> data, we cannot remove the transaction marker. The problem is that we do this
> tracking at the segment level. We do not carry over the ongoing transaction
> state between segments. So if the first entry in a segment is a marker, we
> incorrectly clean it. In the worst case, data from a committed transaction
> could become aborted.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)