Shekharrajak commented on code in PR #22357:
URL: https://github.com/apache/kafka/pull/22357#discussion_r3293882307
##########
server/src/main/java/org/apache/kafka/server/share/fetch/RecordState.java:
##########
@@ -62,8 +63,14 @@ public RecordState validateTransition(RecordState newState)
throws IllegalStateE
throw new IllegalStateException("The state can only be
transitioned to ACQUIRED from AVAILABLE");
}
- // Either the transition is from Available -> Acquired or from
Acquired -> Available/
- // Acknowledged/Archived.
+ if (newState == TX_PENDING && this != ACQUIRED) {
Review Comment:
validation for tx_pending state - it should be after AQUIRED , before
acknowledged or archiving
--
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]
