artemlivshits opened a new pull request, #21469: URL: https://github.com/apache/kafka/pull/21469
Changes: - TransactionMetadata: Log errors instead of throwing when epoch hits MAX_VALUE - ProducerAppendInfo: Allow marker writes at MAX_VALUE epoch for recovery - TransactionsTest: Add comprehensive test case - TransactionCoordinator: Add test accessor for transaction manager Add testRecoveryFromEpochOverflow to verify that the system correctly handles the scenario when producer epoch reaches Short.MaxValue (32767). The test validates: - Epoch can reach Short.MaxValue through transaction timeouts - When epoch overflow is detected, errors are logged but processing continues - Transaction markers at MAX_VALUE epoch are accepted to allow recovery - Producer ID rotation occurs after overflow is detected - New transactions can proceed with rotated producer ID Co-Authored-By: Claude Sonnet 4.5 <[email protected]> -- 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]
