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 43f603cfb7e KAFKA-19351: AsyncConsumer#commitAsync should copy the
input offsets (#19855)
add 7b99ee29a5e KAFKA-19346: Move LogReadResult to server module (#19846)
No new revisions were added by this update.
Summary of changes:
.../java/kafka/server/share/DelayedShareFetch.java | 6 +-
.../kafka/server/share/PendingRemoteFetches.java | 3 +-
.../scala/kafka/server/DelayedRemoteFetch.scala | 5 +-
.../main/scala/kafka/server/ReplicaManager.scala | 164 +++++++--------------
.../kafka/server/share/DelayedShareFetchTest.java | 36 ++---
.../server/share/SharePartitionManagerTest.java | 13 +-
.../kafka/server/DelayedFetchTest.scala | 23 +--
.../kafka/server/DelayedRemoteFetchTest.scala | 23 +--
.../unit/kafka/server/ReplicaManagerTest.scala | 2 +-
.../org/apache/kafka/server/LogReadResult.java | 129 ++++++++++++++++
10 files changed, 240 insertions(+), 164 deletions(-)
create mode 100644
server/src/main/java/org/apache/kafka/server/LogReadResult.java
