You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2021/06/15 17:33:52 UTC
[kafka] branch trunk updated (4b7ad7b -> b67a77d)
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 4b7ad7b KAFKA-12773; Use UncheckedIOException when wrapping IOException (#10749)
add b67a77d KAFKA-12787; Integrate controller snapshoting with raft client (#10786)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 1 +
.../main/scala/kafka/raft/KafkaMetadataLog.scala | 40 +++--
.../kafka/server/epoch/LeaderEpochFileCache.scala | 2 +-
.../scala/kafka/raft/KafkaMetadataLogTest.scala | 196 ++++++++++++++++++---
.../server/epoch/LeaderEpochFileCacheTest.scala | 3 +-
.../kafka/controller/EmptySnapshotReader.java | 52 ------
.../kafka/controller/NoOpSnapshotWriter.java | 55 ------
.../controller/NoOpSnapshotWriterBuilder.java | 28 ---
.../apache/kafka/controller/QuorumController.java | 113 ++++++------
.../apache/kafka/controller/SnapshotGenerator.java | 48 ++---
.../apache/kafka/controller/SnapshotReader.java | 37 ----
.../apache/kafka/controller/SnapshotWriter.java | 55 ------
.../kafka/controller/MockSnapshotReader.java | 55 ------
.../kafka/controller/MockSnapshotWriter.java | 110 ------------
.../kafka/controller/QuorumControllerTest.java | 170 ++++++++++--------
.../kafka/controller/SnapshotGeneratorTest.java | 53 +++---
.../org/apache/kafka/metalog/LocalLogManager.java | 91 ++++++++--
.../kafka/metalog/LocalLogManagerTestEnv.java | 4 +
.../kafka/metalog/MockMetaLogManagerListener.java | 2 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 33 ++--
.../java/org/apache/kafka/raft/RaftClient.java | 19 +-
.../org/apache/kafka/raft/ReplicatedCounter.java | 36 ++--
.../java/org/apache/kafka/raft/ReplicatedLog.java | 30 +++-
.../org/apache/kafka/raft/ValidOffsetAndEpoch.java | 9 +
.../org/apache/kafka/snapshot/SnapshotReader.java | 22 +++
.../org/apache/kafka/snapshot/SnapshotWriter.java | 14 ++
.../kafka/raft/KafkaRaftClientSnapshotTest.java | 70 +++++---
.../test/java/org/apache/kafka/raft/MockLog.java | 67 ++++++-
.../java/org/apache/kafka/raft/MockLogTest.java | 185 ++++++++++++++++---
.../apache/kafka/raft/RaftClientTestContext.java | 29 ++-
.../kafka/snapshot/MockRawSnapshotReader.java | 5 +
.../kafka/snapshot/MockRawSnapshotWriter.java | 5 +
.../kafka/snapshot/SnapshotWriterReaderTest.java | 75 ++++++--
raft/src/test/resources/log4j.properties | 1 +
34 files changed, 975 insertions(+), 740 deletions(-)
delete mode 100644 metadata/src/main/java/org/apache/kafka/controller/EmptySnapshotReader.java
delete mode 100644 metadata/src/main/java/org/apache/kafka/controller/NoOpSnapshotWriter.java
delete mode 100644 metadata/src/main/java/org/apache/kafka/controller/NoOpSnapshotWriterBuilder.java
delete mode 100644 metadata/src/main/java/org/apache/kafka/controller/SnapshotReader.java
delete mode 100644 metadata/src/main/java/org/apache/kafka/controller/SnapshotWriter.java
delete mode 100644 metadata/src/test/java/org/apache/kafka/controller/MockSnapshotReader.java
delete mode 100644 metadata/src/test/java/org/apache/kafka/controller/MockSnapshotWriter.java