Skip to content

Commit

Permalink
KAFKA-16740: Adding skeleton code for Share Fetch and Acknowledge RPC…
Browse files Browse the repository at this point in the history 
… (KIP-932) (apache#16184)

The PR adds skeleton code for Share Fetch and Acknowledge RPCs. The changes include:

1. Defining RPCs in KafkaApis.scala
2. Added new SharePartitionManager class which handles the RPCs handling
3. Added SharePartition class which manages in-memory record states and for fetched data.


Reviewers: David Jacot <djacot@confluent.io>, Andrew Schofield <aschofield@confluent.io>, Manikumar Reddy <manikumar.reddy@gmail.com>
  • Loading branch information
@apoorvmittal10
apoorvmittal10 committed Jun 5, 2024
1 parent b89999b commit 252c1ac
Show file tree
Hide file tree
Showing 4 changed files with 746 additions and 0 deletions.
Loading

0 comments on commit 252c1ac

Please sign in to comment.