kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (4b7ad7b -> b67a77d)
Date Tue, 15 Jun 2021 17:33:52 GMT
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

Mime
View raw message