chia7712 commented on code in PR #21176:
URL: https://github.com/apache/kafka/pull/21176#discussion_r2637840266
##########
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerAppendInfo.java:
##########
@@ -119,6 +119,21 @@ private void checkProducerEpoch(short producerEpoch, long
offset, short transact
boolean invalidEpoch = (transactionVersion >= 2) ? (producerEpoch <=
current) : (producerEpoch < current);
if (invalidEpoch) {
+ // TV2 Idempotent Retry Detection:
+ // When markerEpoch == currentEpoch and no transaction is ongoing,
this is a retry
+ // of a marker that was already successfully written. Common
scenarios:
+ // 1. Coordinator recovery: reloading PREPARE_COMMIT/ABORT from
transaction log
Review Comment:
nit: `from the transaction log`
--
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]
