This is an automated email from the ASF dual-hosted git repository.
mittal pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from c4dc78746e3 KAFKA-18537 Fix flaky
RemoteIndexCacheTest#testCleanerThreadShutdown (#19628)
add 81c3a285a45 KAFKA-19133: Support fetching for multiple remote fetch
topic partitions in a single share fetch request (#19592)
No new revisions were added by this update.
Summary of changes:
.../java/kafka/server/share/DelayedShareFetch.java | 290 +++++++++++----------
.../kafka/server/share/PendingRemoteFetches.java | 85 ++++++
.../kafka/server/share/DelayedShareFetchTest.java | 74 ++++--
3 files changed, 283 insertions(+), 166 deletions(-)
create mode 100644
core/src/main/java/kafka/server/share/PendingRemoteFetches.java
