[KIP-932] Mock Broker: Add transaction lifecycle support#5349
Open
Ankith L (Ankith-Confluent) wants to merge 5 commits intodev_kip-932_queues-for-kafkafrom
Open
[KIP-932] Mock Broker: Add transaction lifecycle support#5349Ankith L (Ankith-Confluent) wants to merge 5 commits intodev_kip-932_queues-for-kafkafrom
Ankith L (Ankith-Confluent) wants to merge 5 commits intodev_kip-932_queues-for-kafkafrom
Conversation
|
🎉 All Contributor License Agreements have been signed. Ready to merge. |
Ankith L (Ankith-Confluent)
changed the title
airlock-confluentinc
bot
force-pushed
the
dev_kip-932_mock_broker_transactions
branch
2 times, most recently
from
eac0ed6 to
d356c86
Compare
- Added transaction state management to handle AddPartitionsToTxn and EndTxn requests. - Introduced structures for tracking active transactions and aborted transactions. - Enhanced ShareFetch and ShareAcknowledge handling to support read_committed isolation level. - Updated share group initialization to include isolation level configuration. - Implemented functions to manage transaction states and partition updates. - Modified existing functions to accommodate new transaction logic and ensure proper locking and state management.
…tion and fetch aborted messages tests
airlock-confluentinc
bot
force-pushed
the
dev_kip-932_mock_broker_transactions
branch
from
d356c86 to
2daf4de
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Adds transaction lifecycle support to the mock broker for KIP-932 share group testing.
EndTxn now writes COMMIT/ABORT control batches to partition logs.
AddPartitionsToTxn tracks partitions in the transaction.
Aborted transaction ranges are recorded per-partition for read_committed filtering.
LSO (Last Stable Offset) is tracked and used to cap ShareFetch acquisition.
Adds isolation_level config API for share groups and 6 unit tests.