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 ca29727 MINOR: Introduce KafkaBroker trait for use in dynamic
reconfiguration (#10019)
add c4ea6fb MINOR: Add ConfigRepository, use in Partition and KafkaApis
(#10005)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/cluster/Partition.scala | 22 +--
.../src/main/scala/kafka/server/ConfigHelper.scala | 216 +++++++++++++++++++++
core/src/main/scala/kafka/server/KafkaApis.scala | 5 +-
core/src/main/scala/kafka/server/KafkaServer.scala | 13 +-
.../main/scala/kafka/server/ReplicaManager.scala | 21 +-
.../main/scala/kafka/server/ZkAdminManager.scala | 188 +-----------------
.../server/metadata/CachedConfigRepository.scala | 106 ++++++++++
.../kafka/server/metadata/ConfigRepository.scala | 52 +++++
.../kafka/server/metadata/ZkConfigRepository.scala | 45 +++++
.../unit/kafka/cluster/AbstractPartitionTest.scala | 7 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 2 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 30 +--
.../AbstractCoordinatorConcurrencyTest.scala | 2 +-
.../server/HighwatermarkPersistenceTest.scala | 21 +-
.../unit/kafka/server/IsrExpirationTest.scala | 5 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 74 ++++---
.../kafka/server/ReplicaManagerQuotasTest.scala | 8 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 46 +++--
.../unit/kafka/server/ZkAdminManagerTest.scala | 21 +-
.../server/epoch/OffsetsForLeaderEpochTest.scala | 18 +-
.../metadata/CachedConfigRepositoryTest.scala | 78 ++++++++
.../server/metadata/ZkConfigRepositoryTest.scala | 54 ++++++
.../unit/kafka/utils/ReplicationUtilsTest.scala | 20 --
.../test/scala/unit/kafka/utils/TestUtils.scala | 14 +-
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 3 +-
.../jmh/metadata/MetadataRequestBenchmark.java | 2 +
.../partition/PartitionMakeFollowerBenchmark.java | 3 +-
.../UpdateFollowerFetchStateBenchmark.java | 3 +-
.../apache/kafka/jmh/server/CheckpointBench.java | 14 +-
29 files changed, 736 insertions(+), 357 deletions(-)
create mode 100644 core/src/main/scala/kafka/server/ConfigHelper.scala
create mode 100644
core/src/main/scala/kafka/server/metadata/CachedConfigRepository.scala
create mode 100644
core/src/main/scala/kafka/server/metadata/ConfigRepository.scala
create mode 100644
core/src/main/scala/kafka/server/metadata/ZkConfigRepository.scala
create mode 100644
core/src/test/scala/unit/kafka/server/metadata/CachedConfigRepositoryTest.scala
create mode 100644
core/src/test/scala/unit/kafka/server/metadata/ZkConfigRepositoryTest.scala
