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(-)