You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sa...@apache.org on 2023/02/22 17:42:13 UTC
[kafka] branch trunk updated (56c84853ec7 -> 069ce59e1e3)

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

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


    from 56c84853ec7 MINOR: Remove unused ZooKeeper log level configuration from `connect-log4j.properties` (#13216)
     add 069ce59e1e3 KAFKA 14714: Move/Rewrite RollParams, LogAppendInfo, and LeaderHwChange to storage module. (#13255)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   2 +-
 core/src/main/scala/kafka/cluster/Partition.scala  |   4 +-
 core/src/main/scala/kafka/log/LogSegment.scala     |   3 +-
 core/src/main/scala/kafka/log/UnifiedLog.scala     | 174 ++---------
 .../main/scala/kafka/raft/KafkaMetadataLog.scala   |  12 +-
 .../scala/kafka/server/AbstractFetcherThread.scala |   4 +-
 .../kafka/server/ReplicaAlterLogDirsThread.scala   |   3 +-
 .../scala/kafka/server/ReplicaFetcherThread.scala  |   4 +-
 .../main/scala/kafka/server/ReplicaManager.scala   |  49 ++--
 .../src/test/scala/other/kafka/StressTestLog.scala |   3 +-
 .../unit/kafka/cluster/PartitionLockTest.scala     |   2 +-
 .../scala/unit/kafka/cluster/PartitionTest.scala   |   2 +-
 .../group/GroupMetadataManagerTest.scala           |  22 +-
 .../LogCleanerParameterizedIntegrationTest.scala   |   2 +-
 .../test/scala/unit/kafka/log/LogCleanerTest.scala |   2 +-
 .../test/scala/unit/kafka/log/LogSegmentTest.scala |  17 +-
 .../test/scala/unit/kafka/log/LogTestUtils.scala   |   2 +-
 .../test/scala/unit/kafka/log/UnifiedLogTest.scala |  16 +-
 .../kafka/server/AbstractFetcherManagerTest.scala  |   2 +-
 .../kafka/server/AbstractFetcherThreadTest.scala   |  37 ++-
 .../kafka/server/ReplicaFetcherThreadTest.scala    |   3 +-
 .../jmh/fetcher/ReplicaFetcherThreadBenchmark.java |   2 +-
 .../{IndexSearchType.java => LeaderHwChange.java}  |   6 +-
 .../kafka/storage/internals/log/LogAppendInfo.java | 321 +++++++++++++++++++++
 .../kafka/storage/internals/log/RollParams.java    |  58 ++++
 25 files changed, 510 insertions(+), 242 deletions(-)
 copy storage/src/main/java/org/apache/kafka/storage/internals/log/{IndexSearchType.java => LeaderHwChange.java} (92%)
 create mode 100644 storage/src/main/java/org/apache/kafka/storage/internals/log/LogAppendInfo.java
 create mode 100644 storage/src/main/java/org/apache/kafka/storage/internals/log/RollParams.java