adixitconfluent opened a new pull request, #17380: URL: https://github.com/apache/kafka/pull/17380
### About In reference to comments https://github.com/apache/kafka/pull/17177#issuecomment-2392017658 and https://github.com/apache/kafka/pull/17177#issuecomment-2392108397 , this PR addresses the following - 1. Move ActionQueue outside DelayedShareFetch class to SharePartitionManager where SharePartitionManager has the ability to add a delayed action to the ActionQueue. 2. Add TopicPartition as a key for delayed share fetch along with SharePartition (that is already present right now). This will be utilized later when we add the code to know if new data has been added to the topic partition. ### Testing The code has been tested with the help of unit tests. -- 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
