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 2020/12/07 22:07:29 UTC
[kafka] branch trunk updated (b8ebcc2 -> ab0807d)

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 b8ebcc2  KAFKA-10798; Ensure response is delayed for failed SASL authentication with connection close delay (#9678)
     add ab0807d  KAFKA-10394: Add classes to read and write snapshot for KIP-630 (#9512)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |   7 +
 .../java/org/apache/kafka/common/utils/Utils.java  |   5 +
 .../main/scala/kafka/raft/KafkaMetadataLog.scala   |  17 ++
 .../org/apache/kafka/raft/KafkaRaftClient.java     |  17 +-
 .../java/org/apache/kafka/raft/QuorumState.java    |  14 +-
 .../java/org/apache/kafka/raft/RaftClient.java     |  13 +
 .../java/org/apache/kafka/raft/ReplicatedLog.java  |  26 ++
 .../kafka/snapshot/FileRawSnapshotReader.java      |  81 ++++++
 .../kafka/snapshot/FileRawSnapshotWriter.java      | 117 +++++++++
 .../apache/kafka/snapshot/RawSnapshotReader.java   |  52 ++++
 .../apache/kafka/snapshot/RawSnapshotWriter.java   |  74 ++++++
 .../org/apache/kafka/snapshot/SnapshotWriter.java  | 156 +++++++++++
 .../java/org/apache/kafka/snapshot/Snapshots.java  |  66 +++++
 .../test/java/org/apache/kafka/raft/MockLog.java   | 107 ++++++++
 .../apache/kafka/raft/RaftClientTestContext.java   |  10 +-
 .../apache/kafka/snapshot/FileRawSnapshotTest.java | 289 +++++++++++++++++++++
 .../apache/kafka/snapshot/SnapshotWriterTest.java  | 116 +++++++++
 17 files changed, 1153 insertions(+), 14 deletions(-)
 create mode 100644 raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java
 create mode 100644 raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java
 create mode 100644 raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java
 create mode 100644 raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotWriter.java
 create mode 100644 raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java
 create mode 100644 raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java
 create mode 100644 raft/src/test/java/org/apache/kafka/snapshot/FileRawSnapshotTest.java
 create mode 100644 raft/src/test/java/org/apache/kafka/snapshot/SnapshotWriterTest.java