jolshan opened a new pull request #9944: URL: https://github.com/apache/kafka/pull/9944
Most components are ready here. Topic IDs replace topic names in fetch requests. I need to look into FetchSession more. Currently testCreateIncrementalFetchWithPartitionsWithIdError() fails because FetchSession does not cache partitions that resulted in UNKNOWN_TOPIC_ID error. I need to figure out if this is something that should be done. I also plan to add a test to simulate a rolling upgrade where some brokers do not have topic IDs in metadata. I want to ensure that Consumers can still poll and get data. I will also run the various fetch benchmarks and compare the results to trunk ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
