This is an automated email from the ASF dual-hosted git repository.
jsancio pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d1e0d2b HOTFIX: Set version of jgit to avoid unsupported version
error (#11554)
add 42306ba KAFKA-12932: Interfaces for SnapshotReader and SnapshotWriter
(#11529)
No new revisions were added by this update.
Summary of changes:
.../kafka/server/RaftClusterSnapshotTest.scala | 6 +-
.../metadata/BrokerMetadataSnapshotterTest.scala | 4 +-
.../kafka/controller/QuorumControllerTest.java | 5 +-
.../kafka/controller/SnapshotGeneratorTest.java | 5 +-
.../org/apache/kafka/metalog/LocalLogManager.java | 8 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 8 +-
...pshotReader.java => RecordsSnapshotReader.java} | 44 ++----
...pshotWriter.java => RecordsSnapshotWriter.java} | 67 ++-------
.../org/apache/kafka/snapshot/SnapshotReader.java | 113 +-------------
.../org/apache/kafka/snapshot/SnapshotWriter.java | 166 +--------------------
.../kafka/raft/KafkaRaftClientSnapshotTest.java | 5 +-
.../apache/kafka/raft/RaftClientTestContext.java | 2 +-
.../apache/kafka/raft/RaftEventSimulationTest.java | 3 +-
.../kafka/snapshot/SnapshotWriterReaderTest.java | 4 +-
14 files changed, 69 insertions(+), 371 deletions(-)
copy raft/src/main/java/org/apache/kafka/snapshot/{SnapshotReader.java =>
RecordsSnapshotReader.java} (73%)
copy raft/src/main/java/org/apache/kafka/snapshot/{SnapshotWriter.java =>
RecordsSnapshotWriter.java} (75%)
