Bill Bejeck created KAFKA-20478:
-----------------------------------
Summary: 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
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)
