kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated (0b6d6b1 -> d3ec9f9)
Date Tue, 29 Jun 2021 16:38:52 GMT
This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 0b6d6b1  KAFKA-12520: Ensure log loading does not truncate producer state unless
required (#10763)
     add d3ec9f9  KAFKA-12952 Add header and footer records for raft snapshots (#10899)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |   1 +
 .../kafka/common/record/ControlRecordType.java     |  13 ++-
 .../kafka/common/record/ControlRecordUtils.java    |  38 +++++++-
 .../apache/kafka/common/record/MemoryRecords.java  |  76 +++++++++++++--
 .../kafka/common/record/MemoryRecordsBuilder.java  |  14 ++-
 .../common/message/LeaderChangeMessage.json        |   2 +
 .../common/message/SnapshotFooterRecord.json       |   9 +-
 ...rokerRequest.json => SnapshotHeaderRecord.json} |  12 +--
 .../common/record/ControlRecordUtilsTest.java      |   2 +-
 .../apache/kafka/controller/QuorumController.java  |   3 +-
 .../kafka/controller/SnapshotGeneratorTest.java    |  22 ++++-
 .../org/apache/kafka/metalog/LocalLogManager.java  |  32 ++++---
 .../org/apache/kafka/raft/KafkaRaftClient.java     |  15 +--
 .../java/org/apache/kafka/raft/LeaderState.java    |   3 +
 .../java/org/apache/kafka/raft/RaftClient.java     |   5 +-
 .../org/apache/kafka/raft/ReplicatedCounter.java   |   2 +-
 .../kafka/raft/internals/BatchAccumulator.java     | 106 +++++++++++++++++----
 .../org/apache/kafka/snapshot/SnapshotReader.java  |  35 ++++++-
 .../org/apache/kafka/snapshot/SnapshotWriter.java  |  92 +++++++++++++++---
 .../kafka/raft/KafkaRaftClientSnapshotTest.java    |  27 +++---
 .../kafka/snapshot/SnapshotWriterReaderTest.java   |  98 ++++++++++++++++++-
 21 files changed, 504 insertions(+), 103 deletions(-)
 copy metadata/src/main/resources/common/metadata/RemoveFeatureLevelRecord.json => clients/src/main/resources/common/message/SnapshotFooterRecord.json
(83%)
 copy clients/src/main/resources/common/message/{UnregisterBrokerRequest.json => SnapshotHeaderRecord.json}
(71%)

Mime
View raw message