Chirag Wadhwa
Chirag Wadhwa
### About This PR adds acknowledge code in SharePartitionManager. Internally, the record acknowledgements happen at the SharePartition level. SharePartitionManager identifies the SharePartitions and calls their acknowledge method to actually acknowledge...
### 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...
This PR contains Integration Tests for Share Fetch and Share Acknowledge APIs Reference: [KAFKA-17290](https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-17290?filter=allopenissues)
The test testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers was recently found to be flaky. Making the following small change that could potentially resolve the issue. Earlier, 1000 records were being produced and then 3 consecutive...