You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by js...@apache.org on 2021/11/30 18:50:59 UTC
[kafka] branch trunk updated (d1e0d2b -> 42306ba)
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%)