adixitconfluent opened a new pull request, #16263:
URL: https://github.com/apache/kafka/pull/16263
### About
KIP-932 introduces share sessions for share groups. This PR implements share
sessions and contexts for incoming share fetch requests on broker. The changes
include:
1. Defined `CachedSharePartition` class which are stored in share sessions.
2. Defined `ShareSessionKey`, `ShareSession` classes.
3. Defined `ShareSessionCache` class which caches all the share sessions and
has evict policy defined as per KIP-932
4. Defined the 2 types of contexts -
a. `ShareSessionContext` - for share session fetch request.
b. `FinalContext` - for final share fetch request (epoch = -1).
5. Defined `newContext` function which returns the created/updated context
on receiving share fetch request on broker.
### Testing
The added code has been tested with the help of unit tests present in the PR.
--
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
