kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated (acf39fe -> 242f65e)
Date Sat, 06 Feb 2021 00:28:54 GMT
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


Mime
View raw message