This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d2a05d7 Bump trunk to 3.1.0-SNAPSHOT (#10981)
add 7bd55f5 KAFKA-12998: Implement broker-side KRaft snapshots (#10931)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
.../requests/DescribeClientQuotasResponse.java | 1 -
.../kafka/server/AbstractFetcherManager.scala | 6 +
.../src/main/scala/kafka/server/BrokerServer.scala | 114 +++---
.../main/scala/kafka/server/ConfigHandler.scala | 4 +-
.../scala/kafka/server/DelayedDeleteRecords.scala | 3 -
.../scala/kafka/server/FinalizedFeatureCache.scala | 21 +
core/src/main/scala/kafka/server/KafkaApis.scala | 18 +-
core/src/main/scala/kafka/server/KafkaServer.scala | 2 +-
.../main/scala/kafka/server/MetadataCache.scala | 15 +-
.../main/scala/kafka/server/MetadataSupport.scala | 18 +-
.../kafka/server/RaftReplicaChangeDelegate.scala | 252 ------------
.../scala/kafka/server/RaftReplicaManager.scala | 404 ------------------
.../main/scala/kafka/server/ReplicaManager.scala | 265 ++++++++++--
.../server/metadata/BrokerMetadataListener.scala | 332 +++++++--------
.../server/metadata/BrokerMetadataPublisher.scala | 249 ++++++++++++
.../server/metadata/CachedConfigRepository.scala | 111 -----
.../kafka/server/metadata/ClientQuotaCache.scala | 307 --------------
.../metadata/ClientQuotaMetadataManager.scala | 97 ++---
.../kafka/server/metadata/KRaftMetadataCache.scala | 354 ++++++++++++++++
.../kafka/server/metadata/MetadataBrokers.scala | 150 -------
.../kafka/server/metadata/MetadataImage.scala | 137 -------
.../kafka/server/metadata/MetadataPartitions.scala | 355 ----------------
.../metadata/MetadataPublisher.scala} | 38 +-
.../kafka/server/metadata/RaftMetadataCache.scala | 394 ------------------
.../server/metadata/MetadataBrokersTest.scala | 90 ----
.../server/metadata/MetadataPartitionsTest.scala | 324 ---------------
.../server/metadata/MockConfigRepository.scala | 2 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 2 +-
.../AbstractCoordinatorConcurrencyTest.scala | 2 +-
.../server/HighwatermarkPersistenceTest.scala | 5 +-
.../unit/kafka/server/IsrExpirationTest.scala | 3 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 58 ++-
.../unit/kafka/server/MetadataCacheTest.scala | 113 +++++-
.../server/RaftReplicaChangeDelegateTest.scala | 151 -------
.../unit/kafka/server/RaftReplicaManagerTest.scala | 317 ---------------
.../kafka/server/ReplicaManagerQuotasTest.scala | 4 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 115 +++++-
.../server/epoch/OffsetsForLeaderEpochTest.scala | 8 +-
.../metadata/BrokerMetadataListenerTest.scala | 248 +++--------
.../metadata/CachedConfigRepositoryTest.scala | 78 ----
.../metadata/ClientQuotaMetadataManagerTest.scala | 452 ---------------------
.../test/scala/unit/kafka/utils/TestUtils.scala | 23 +-
.../apache/kafka/jmh/server/CheckpointBench.java | 2 -
.../org/apache/kafka/image/ClientQuotasImage.java | 9 +
.../java/org/apache/kafka/image/MetadataDelta.java | 4 +
46 files changed, 1433 insertions(+), 4225 deletions(-)
delete mode 100644
core/src/main/scala/kafka/server/RaftReplicaChangeDelegate.scala
delete mode 100644 core/src/main/scala/kafka/server/RaftReplicaManager.scala
create mode 100644
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
delete mode 100644
core/src/main/scala/kafka/server/metadata/CachedConfigRepository.scala
delete mode 100644
core/src/main/scala/kafka/server/metadata/ClientQuotaCache.scala
create mode 100644
core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala
delete mode 100644
core/src/main/scala/kafka/server/metadata/MetadataBrokers.scala
delete mode 100755
core/src/main/scala/kafka/server/metadata/MetadataImage.scala
delete mode 100644
core/src/main/scala/kafka/server/metadata/MetadataPartitions.scala
copy core/src/main/scala/kafka/{utils/DelayedItem.scala =>
server/metadata/MetadataPublisher.scala} (54%)
delete mode 100644
core/src/main/scala/kafka/server/metadata/RaftMetadataCache.scala
delete mode 100644
core/src/test/scala/kafka/server/metadata/MetadataBrokersTest.scala
delete mode 100644
core/src/test/scala/kafka/server/metadata/MetadataPartitionsTest.scala
delete mode 100644
core/src/test/scala/unit/kafka/server/RaftReplicaChangeDelegateTest.scala
delete mode 100644
core/src/test/scala/unit/kafka/server/RaftReplicaManagerTest.scala
delete mode 100644
core/src/test/scala/unit/kafka/server/metadata/CachedConfigRepositoryTest.scala
delete mode 100644
core/src/test/scala/unit/kafka/server/metadata/ClientQuotaMetadataManagerTest.scala
