This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e8ad80e MINOR: remove explicit passing of AdminClient into
StreamsPartitionAssignor (#9384)
add fcc7c2d MINOR: Handle lastFetchedEpoch/divergingEpoch in FetchSession
and DelayedFetch (#9434)
No new revisions were added by this update.
Summary of changes:
.../src/main/scala/kafka/server/DelayedFetch.scala | 15 +++++
.../src/main/scala/kafka/server/FetchSession.scala | 12 ++--
.../main/scala/kafka/server/ReplicaManager.scala | 6 +-
.../kafka/server/DelayedFetchTest.scala | 66 ++++++++++++++++++----
.../scala/unit/kafka/server/FetchSessionTest.scala | 61 ++++++++++++++++++++
5 files changed, 144 insertions(+), 16 deletions(-)
