This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from bee3cf7 MINOR: Remove unused Utils.delete (#10622)
add 6203bf8 KAFKA-12154; Raft Snapshot Loading API (#10085)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 1 +
.../main/scala/kafka/tools/TestRaftServer.scala | 15 +-
.../src/main/java/org/apache/kafka/raft/Batch.java | 133 ++++++++++++
.../java/org/apache/kafka/raft/BatchReader.java | 57 +----
.../java/org/apache/kafka/raft/FollowerState.java | 2 +
.../org/apache/kafka/raft/KafkaRaftClient.java | 138 ++++++++----
.../java/org/apache/kafka/raft/LeaderState.java | 26 ++-
.../java/org/apache/kafka/raft/RaftClient.java | 28 ++-
.../org/apache/kafka/raft/ReplicatedCounter.java | 99 ++++++---
.../java/org/apache/kafka/raft/ReplicatedLog.java | 11 +-
.../kafka/raft/internals/MemoryBatchReader.java | 1 +
.../kafka/raft/internals/RecordsBatchReader.java | 189 +++++-----------
.../kafka/raft/internals/RecordsIterator.java | 239 +++++++++++++++++++++
.../kafka/raft/metadata/MetaLogRaftShim.java | 9 +-
.../kafka/snapshot/FileRawSnapshotReader.java | 13 +-
.../kafka/snapshot/FileRawSnapshotWriter.java | 109 ++++++----
.../apache/kafka/snapshot/RawSnapshotReader.java | 27 +--
.../apache/kafka/snapshot/RawSnapshotWriter.java | 23 +-
.../org/apache/kafka/snapshot/SnapshotReader.java | 81 +++++++
.../org/apache/kafka/snapshot/SnapshotWriter.java | 19 +-
.../kafka/raft/KafkaRaftClientSnapshotTest.java | 187 +++++++++++++++-
.../org/apache/kafka/raft/KafkaRaftClientTest.java | 67 ++++--
.../test/java/org/apache/kafka/raft/MockLog.java | 110 ++++++----
.../java/org/apache/kafka/raft/MockLogTest.java | 141 ++++++------
.../apache/kafka/raft/RaftClientTestContext.java | 102 +++++++--
.../apache/kafka/raft/RaftEventSimulationTest.java | 104 +++++++--
.../raft/internals/MemoryBatchReaderTest.java | 20 +-
.../raft/internals/RecordsBatchReaderTest.java | 57 +----
.../kafka/raft/internals/RecordsIteratorTest.java | 188 ++++++++++++++++
.../apache/kafka/snapshot/FileRawSnapshotTest.java | 62 +++---
...iterTest.java => SnapshotWriterReaderTest.java} | 44 +++-
.../apache/kafka/shell/MetadataNodeManager.java | 18 +-
32 files changed, 1676 insertions(+), 644 deletions(-)
create mode 100644 raft/src/main/java/org/apache/kafka/raft/Batch.java
create mode 100644
raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java
create mode 100644
raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java
create mode 100644
raft/src/test/java/org/apache/kafka/raft/internals/RecordsIteratorTest.java
rename raft/src/test/java/org/apache/kafka/snapshot/{SnapshotWriterTest.java
=> SnapshotWriterReaderTest.java} (77%)
