Shekharrajak opened a new pull request, #22357: URL: https://github.com/apache/kafka/pull/22357
Share groups (KIP-932) have no equivalent of sendOffsetsToTransaction. There is no way to atomically bind a share-group acknowledgment to a producer transaction, blocking EOS for share-group-based read-process-write pipelines. #### Description This is the foundational layer for KIP-1289. It does not include the broker-side RPC handler (follow-up PR). - RecordState — new TX_PENDING state (server module) - InFlightState — transactional staging (server module) - ShareGroupMetadata (clients module) - ShareConsumer.shareGroupMetadata() — fires a background event to read live membership state from ShareMembershipManager - Wire schema (clients module)- TxnShareAcknowledgeRequest / TxnShareAcknowledgeResponse (apiKey 93, v0) - Producer EOS flow (clients module) - Producer.sendShareAcknowledgementsToTransaction( #### tests • RecordStateTest — full 6-state transition matrix including all TX_PENDING paths • InFlightStateTxnTest #### follow up • Broker-side handleTransactionnShareAcknowledge handler in Kafka Apis.scala • ShareCoordinatorShard.replayEndTransactionMarker() real body • SharePartition TX_PENDING acquisition exclusion • IT tests (require broker handler) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
