This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 305f134 MINOR: Small logging fixes in AbstractCoordinator (#7230)
add 6ae1af8 KAFKA-9198; Complete purgatory operations on receiving
StopReplica (#7701)
No new revisions were added by this update.
Summary of changes:
.../src/main/scala/kafka/server/DelayedFetch.scala | 7 +-
.../main/scala/kafka/server/DelayedProduce.scala | 17 ++-
.../main/scala/kafka/server/ReplicaManager.scala | 37 ++++--
.../unit/kafka/server/ReplicaManagerTest.scala | 126 +++++++++++++++++++--
4 files changed, 155 insertions(+), 32 deletions(-)