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 b3905d9 KAFKA-8613: New APIs for Controlling Grace Period for
Windowed Operations (#10926)
add 1b7ab8e KAFKA-12863: Configure controller snapshot generation (#10812)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/raft/RaftManager.scala | 12 +-
.../main/scala/kafka/server/ControllerServer.scala | 1 +
core/src/main/scala/kafka/server/KafkaConfig.scala | 13 +-
.../java/kafka/testkit/KafkaClusterTestKit.java | 16 +-
.../kafka/server/RaftClusterSnapshotTest.scala | 79 ++++++++++
.../metadata/BrokerMetadataListenerTest.scala | 9 +-
.../apache/kafka/controller/QuorumController.java | 75 +++++++--
.../kafka/controller/QuorumControllerTest.java | 175 ++++++++++++++++++++-
.../org/apache/kafka/metalog/LocalLogManager.java | 114 +++++++++++---
.../kafka/metalog/LocalLogManagerTestEnv.java | 8 +
.../src/main/java/org/apache/kafka/raft/Batch.java | 25 ++-
.../org/apache/kafka/raft/KafkaRaftClient.java | 18 ++-
.../kafka/raft/internals/RecordsIterator.java | 9 +-
.../raft/internals/MemoryBatchReaderTest.java | 6 +-
.../raft/internals/RecordsBatchReaderTest.java | 14 +-
.../kafka/raft/internals/RecordsIteratorTest.java | 68 ++++++--
.../org/apache/kafka/shell/SnapshotFileReader.java | 1 +
17 files changed, 547 insertions(+), 96 deletions(-)
create mode 100644
core/src/test/scala/integration/kafka/server/RaftClusterSnapshotTest.scala
