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 a6d8988179d MINOR: Clarify docs for Streams config
max.warmup.replicas. (#13082)
add 97105a8e581 KAFKA-14726 Move/rewrite of LogReadInfo,
LogOffsetSnapshot, LogStartOffsetIncrementReason to storage module (#13304)
No new revisions were added by this update.
Summary of changes:
.../server/ReplicaFetcherTierStateMachine.java | 5 +-
core/src/main/scala/kafka/cluster/Partition.scala | 34 +++++-----
core/src/main/scala/kafka/log/UnifiedLog.scala | 48 +++-----------
.../main/scala/kafka/raft/KafkaMetadataLog.scala | 8 +--
.../kafka/server/ReplicaAlterLogDirsThread.scala | 5 +-
.../scala/kafka/server/ReplicaFetcherThread.scala | 10 ++-
.../main/scala/kafka/server/ReplicaManager.scala | 6 +-
.../kafka/server/DelayedFetchTest.scala | 5 +-
.../scala/kafka/raft/KafkaMetadataLogTest.scala | 10 +--
.../unit/kafka/cluster/PartitionLockTest.scala | 2 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 10 +--
.../unit/kafka/log/LogCleanerManagerTest.scala | 14 ++--
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 16 ++---
.../test/scala/unit/kafka/log/LogLoaderTest.scala | 10 +--
.../test/scala/unit/kafka/log/UnifiedLogTest.scala | 26 ++++----
.../scala/unit/kafka/server/LogOffsetTest.scala | 5 +-
.../kafka/server/ReplicaManagerQuotasTest.scala | 24 +++----
.../unit/kafka/server/ReplicaManagerTest.scala | 4 +-
.../storage/internals/log/LogOffsetSnapshot.java | 75 ++++++++++++++++++++++
.../kafka/storage/internals/log/LogReadInfo.java | 60 +++++++++++++++++
...ion.java => LogStartOffsetIncrementReason.java} | 22 ++++---
21 files changed, 252 insertions(+), 147 deletions(-)
create mode 100644
storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetSnapshot.java
create mode 100644
storage/src/main/java/org/apache/kafka/storage/internals/log/LogReadInfo.java
copy
storage/src/main/java/org/apache/kafka/storage/internals/log/{IndexOffsetOverflowException.java
=> LogStartOffsetIncrementReason.java} (66%)
