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 ef453dd1ad4 KAFKA-12634 enforce checkpoint after restoration (#13269)
add d5e216d6183 KAFKA-14617: Fill broker epochs to the
AlterPartitionRequest (#13489)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/api/LeaderAndIsr.scala | 32 +++-
core/src/main/scala/kafka/cluster/Partition.scala | 63 ++++++-
core/src/main/scala/kafka/cluster/Replica.scala | 21 ++-
.../scala/kafka/server/AlterPartitionManager.scala | 5 +-
.../main/scala/kafka/server/ReplicaManager.scala | 2 +-
.../kafka/server/metadata/KRaftMetadataCache.scala | 5 +
.../main/scala/kafka/zk/ZkMigrationClient.scala | 2 +-
.../unit/kafka/cluster/AbstractPartitionTest.scala | 5 +
.../unit/kafka/cluster/PartitionLockTest.scala | 1 +
.../scala/unit/kafka/cluster/PartitionTest.scala | 198 ++++++++++++++++++---
.../scala/unit/kafka/cluster/ReplicaTest.scala | 17 +-
.../kafka/server/AlterPartitionManagerTest.scala | 61 ++++++-
.../unit/kafka/server/IsrExpirationTest.scala | 18 +-
.../unit/kafka/server/MetadataCacheTest.scala | 21 +++
.../server/ReplicaManagerConcurrencyTest.scala | 6 +-
.../unit/kafka/zk/ZkMigrationClientTest.scala | 4 +-
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 2 +-
.../partition/PartitionMakeFollowerBenchmark.java | 2 +-
.../UpdateFollowerFetchStateBenchmark.java | 10 +-
19 files changed, 400 insertions(+), 75 deletions(-)
