KAFKA-13111: Re-evaluate Fetch Sessions when using topic IDs#11331

Merged

dajac merged 37 commits into

apache:trunkfrom

jolshan:KAFKA-13111

Nov 15, 2021

Commits on Sep 8, 2021

change to topicIdPartition
jolshan
committed

Commits on Sep 9, 2021

Handle unknown topic IDs for full/sessionless cases.
jolshan
committed
Handling some incremental session things. Still need to handle partitions already in the session and inconsistent IDs.
jolshan
committed
fix inconsistent topic ID handling for sessionless fetch contexts
jolshan
committed

Commits on Sep 10, 2021

finish up first draft of handling incremental partitions
jolshan
committed

Commits on Sep 16, 2021

Remove unnecessary error handling
jolshan
committed

Commits on Sep 20, 2021

Commits on Sep 21, 2021

Change equality checks based on which version we are using
jolshan
committed

Commits on Sep 28, 2021

Commits on Sep 29, 2021

Change FetchSessionHandler again to handle creating a new session right away.
jolshan
committed

Commits on Oct 6, 2021

Commits on Oct 12, 2021

KAFKA-13111; FetchSessionHandler WIP
dajac
committed

Commits on Oct 13, 2021

more refactor
dajac
committed

Commits on Oct 22, 2021

Commits on Oct 26, 2021

remove inconsistent topic ID from top level, put toForget after fetchData when updating session
jolshan
committed

Commits on Oct 28, 2021

Add some testing for edge cases
jolshan
committed

Commits on Nov 4, 2021

Respond to review comments
jolshan
committed

Commits on Nov 5, 2021

Respond to comments on tests
jolshan
committed

Commits on Nov 9, 2021