This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 16186eabcdd KAFKA-16927; Handle expanding leader endpoints (#17363)
add 455c79c339a KAFKA-17509: Introduce a delayed action queue to complete
purgatory actions outside purgatory. (#17177)
No new revisions were added by this update.
Summary of changes:
.../server/builders/ReplicaManagerBuilder.java | 4 +-
.../java/kafka/server/share/DelayedShareFetch.java | 20 ++-
.../kafka/server/share/SharePartitionManager.java | 16 ++-
.../src/main/scala/kafka/server/BrokerServer.scala | 9 +-
.../main/scala/kafka/server/ReplicaManager.scala | 8 +-
.../kafka/server/share/DelayedShareFetchTest.java | 143 ++++++++++++++++++++-
.../server/share/SharePartitionManagerTest.java | 11 +-
7 files changed, 193 insertions(+), 18 deletions(-)
