mumrah commented on PR #15007: URL: https://github.com/apache/kafka/pull/15007#issuecomment-1857890630
Thanks for taking a look @jsancio! I'll answer some related questions here. If an error occurs inside the `readAllMetadata` call in KRaftMetadataDriver, the catch block will explicitly abort the transaction. If the controller crashes during this call or any time before committing the EndTransactionRecord, then the next active controller will abort the partial transaction. This is the same case as a controller not crashing but losing leadership during the migration (like from a timeout). The logic for detecting and aborting partial transactions is in ActivationRecordsGenerator. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
