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 3f465fc1b62 KAFKA-19202: Enable KIP-1071 in
streams_standby_replica_test.py (#19625)
add 33abb655ebd KAFKA-19215: Handle share partition fetch lock cleanly
using tokens (#19598)
No new revisions were added by this update.
Summary of changes:
.../java/kafka/server/share/DelayedShareFetch.java | 29 ++-
.../java/kafka/server/share/SharePartition.java | 50 +++--
.../kafka/server/share/DelayedShareFetchTest.java | 215 ++++++++++++++-------
.../server/share/SharePartitionManagerTest.java | 40 ++--
.../kafka/server/share/SharePartitionTest.java | 39 +++-
.../unit/kafka/server/ReplicaManagerTest.scala | 2 +-
6 files changed, 250 insertions(+), 125 deletions(-)
