You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/09/17 21:13:59 UTC
[kafka] branch trunk updated (1b0294d -> 074a3da)
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 1b0294d MINOR: Let the list-store return null in putifabsent (#11335)
add 074a3da MINOR: Make ReplicaManager, LogManager, KafkaApis easier to construct (#11320)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control-core.xml | 7 +
checkstyle/suppressions.xml | 2 +-
.../kafka/server/builders/KafkaApisBuilder.java | 197 +++++++++++++++++++++
.../kafka/server/builders/LogManagerBuilder.java | 167 +++++++++++++++++
.../server/builders/ReplicaManagerBuilder.java | 173 ++++++++++++++++++
.../src/main/scala/kafka/server/BrokerServer.scala | 42 ++++-
core/src/main/scala/kafka/server/KafkaServer.scala | 50 ++++--
.../main/scala/kafka/server/ReplicaManager.scala | 64 +++----
.../test/scala/unit/kafka/log/LogLoaderTest.scala | 29 ++-
.../server/HighwatermarkPersistenceTest.scala | 27 ++-
.../unit/kafka/server/IsrExpirationTest.scala | 14 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 39 ++--
.../kafka/server/ReplicaManagerQuotasTest.scala | 14 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 137 ++++++++++----
.../server/epoch/OffsetsForLeaderEpochTest.scala | 40 +++--
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 63 ++++---
.../jmh/metadata/MetadataRequestBenchmark.java | 44 ++---
.../partition/PartitionMakeFollowerBenchmark.java | 43 +++--
.../UpdateFollowerFetchStateBenchmark.java | 43 ++---
.../apache/kafka/jmh/server/CheckpointBench.java | 28 ++-
.../kafka/jmh/server/PartitionCreationBench.java | 86 +++++----
21 files changed, 1019 insertions(+), 290 deletions(-)
create mode 100644 core/src/main/java/kafka/server/builders/KafkaApisBuilder.java
create mode 100644 core/src/main/java/kafka/server/builders/LogManagerBuilder.java
create mode 100644 core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java