kafka
kafka copied to clipboard
KAFKA-16745: Implemented handleShareFetchRequest RPC including unit tests
About
Implemented handleShareFetch request RPC in KafkaApis.scala. This method is called whenever the client sends a Share Fetch request to the broker. Although Share Fetch request support acknowledgements, since the logic for acknowledging records is not completely implemented in SharePartitionManager.java class, this method currently includes placeholder code for acknowledging, which will be replaced by the actual functionality in the upcoming PRs.
Testing
Added unit tests to cover the new functionality added in KafkaApisTest