You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rs...@apache.org on 2020/10/16 08:59:29 UTC
[kafka] branch trunk updated (e8ad80e -> fcc7c2d)
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(-)