You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/06/29 16:38:52 UTC
[kafka] branch trunk updated (0b6d6b1 -> d3ec9f9)
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%)