@lindong28 Would you have time to review this? The changes are mostly mechanical. I have avoided updating any of the internal handling logic other than in trivial ways. Basically I'm trying to get all of the boilerplate out of the way so that reviewing the changes to the logic will be easier.
The test failure is because the replica fetcher is (intentionally) not using the latest version of the fetch api. I'm thinking of ways to fix this, but one option is to not expose the new versions in the corresponding `XXXRequest.schemaVersions()` methods until the new behavior has been implemented. [ Full content available at: https://github.com/apache/kafka/pull/5564 ] This message was relayed via gitbox.apache.org for [email protected]
