Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • EndTxn(COMMIT) transitions the transaction to PREPARE_COMMIT in __transaction_state
  • WriteTxnMarkers dispatches commit markers to all partitions (data topics, __consumer_offsets, and now __share_group_state)
  • When all markers are confirmed, state transitions to COMPLETE_COMMIT


Transaction metadata stays in __transaction_state.

Share acks are written transactionally to __share_group_state using CoordinatorRuntime.scheduleTransactionalWriteOperation().

6. Wire Protocol Details

TxnShareAcknowledgeRequest

...