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/02/06 00:28:54 UTC

[kafka] branch trunk updated (acf39fe -> 242f65e)

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 acf39fe  MINOR: Allow KafkaApis to be configured for Raft controller quorums (#10045)
     add 242f65e  Refactor the MetadataCache into two implementations (#10049)

No new revisions were added by this update.

Summary of changes:
 .../server/BrokerToControllerChannelManager.scala  |   2 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |   7 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |   2 +-
 .../main/scala/kafka/server/MetadataCache.scala    |  90 ++++-
 .../main/scala/kafka/server/ZkAdminManager.scala   |   8 +-
 .../kafka/server/metadata/MetadataBrokers.scala    |  13 +-
 .../kafka/server/metadata/MetadataImage.scala      |   4 +
 .../kafka/server/metadata/MetadataPartitions.scala |  14 +-
 .../kafka/server/metadata/RaftMetadataCache.scala  | 390 +++++++++++++++++++++
 .../server/HighwatermarkPersistenceTest.scala      |   4 +-
 .../unit/kafka/server/IsrExpirationTest.scala      |   2 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |   8 +-
 .../unit/kafka/server/MetadataCacheTest.scala      | 103 +++---
 .../kafka/server/ReplicaManagerQuotasTest.scala    |   2 +-
 .../unit/kafka/server/ReplicaManagerTest.scala     |   8 +-
 .../server/epoch/OffsetsForLeaderEpochTest.scala   |   6 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |   7 +-
 .../jmh/metadata/MetadataRequestBenchmark.java     |   2 +-
 .../apache/kafka/jmh/server/CheckpointBench.java   |   2 +-
 19 files changed, 584 insertions(+), 90 deletions(-)
 create mode 100644 core/src/main/scala/kafka/server/metadata/RaftMetadataCache.scala