You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/04/17 19:10:00 UTC

[jira] [Assigned] (KAFKA-20478) KIP-892: Update ProcessorStateManager for transactional commit/rollback

     [ https://issues.apache.org/jira/browse/KAFKA-20478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Bill Bejeck reassigned KAFKA-20478:
-----------------------------------

    Assignee: Nicholas Telford

> KIP-892: Update ProcessorStateManager for transactional commit/rollback
> -----------------------------------------------------------------------
>
>                 Key: KAFKA-20478
>                 URL: https://issues.apache.org/jira/browse/KAFKA-20478
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Bill Bejeck
>            Assignee: Nicholas Telford
>            Priority: Major
>
> Update ProcessorStateManager for isolation-level-aware state management.
> - approximateNumUncommittedBytes() — sum across all registered stores
> - Under READ_COMMITTED + EOS: on TaskCorruptedException, do NOT wipe state stores — discard uncommitted batch (rollback)
> - Under READ_UNCOMMITTED + EOS: preserve current behavior (wipe on corruption)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)