You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2021/04/20 16:25:06 UTC

[kafka] branch trunk updated (7ca13d3 -> 0b46441)

This is an automated email from the ASF dual-hosted git repository.

junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 7ca13d3  MINOR: Fix nonsense test line from TopicCommandTest (#10551)
     add 0b46441  KAFKA-12553: Refactor recovery logic to introduce LogLoader (#10478)

No new revisions were added by this update.

Summary of changes:
 core/src/main/scala/kafka/log/Log.scala            | 1070 ++++++-------
 core/src/main/scala/kafka/log/LogCleaner.scala     |   11 +-
 core/src/main/scala/kafka/log/LogConfig.scala      |    7 +
 core/src/main/scala/kafka/log/LogLoader.scala      |  525 +++++++
 .../unit/kafka/cluster/PartitionLockTest.scala     |   47 +-
 .../scala/unit/kafka/cluster/PartitionTest.scala   |   48 +-
 .../unit/kafka/log/LogCleanerManagerTest.scala     |   37 +-
 .../test/scala/unit/kafka/log/LogCleanerTest.scala |   40 +-
 .../test/scala/unit/kafka/log/LogLoaderTest.scala  | 1501 ++++++++++++++++++
 core/src/test/scala/unit/kafka/log/LogTest.scala   | 1587 ++------------------
 .../test/scala/unit/kafka/log/LogTestUtils.scala   |  242 ++-
 .../unit/kafka/server/ReplicaManagerTest.scala     |   44 +-
 .../scala/unit/kafka/utils/SchedulerTest.scala     |   27 +-
 13 files changed, 3004 insertions(+), 2182 deletions(-)
 create mode 100644 core/src/main/scala/kafka/log/LogLoader.scala
 create mode 100644 core/src/test/scala/unit/kafka/log/LogLoaderTest.scala