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/04/06 17:19:25 UTC
[kafka] branch trunk updated (137491c -> 7bc84d6)
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 137491c MINOR: Support ExponentialBackoff without jitter (#10455)
add 7bc84d6 KAFKA-12467: Implement QuorumController snapshot generation (#10366)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +
core/src/test/java/kafka/test/MockController.java | 5 +
.../controller/ClientQuotaControlManager.java | 58 ++++++-
.../kafka/controller/ClusterControlManager.java | 67 +++++++-
.../controller/ConfigurationControlManager.java | 40 +++++
.../org/apache/kafka/controller/Controller.java | 8 +
.../EmptySnapshotReader.java} | 26 +--
.../kafka/controller/FeatureControlManager.java | 51 ++++--
.../apache/kafka/controller/QuorumController.java | 187 +++++++++++++++++++--
.../controller/ReplicationControlManager.java | 44 +++++
.../apache/kafka/controller/SnapshotGenerator.java | 146 ++++++++++++++++
.../apache/kafka/controller/SnapshotReader.java | 19 ++-
.../apache/kafka/controller/SnapshotWriter.java | 55 ++++++
.../apache/kafka/timeline/SnapshotRegistry.java | 4 +
.../controller/ClientQuotaControlManagerTest.java | 48 +++++-
.../controller/ClusterControlManagerTest.java | 63 ++++++-
.../ConfigurationControlManagerTest.java | 10 +-
.../kafka/controller/ControllerTestUtils.java | 51 ++++++
.../controller/FeatureControlManagerTest.java | 26 ++-
.../kafka/controller/MockSnapshotReader.java | 27 +--
.../kafka/controller/MockSnapshotWriter.java | 94 +++++++++++
.../kafka/controller/NoOpSnapshotWriter.java} | 23 ++-
.../controller/NoOpSnapshotWriterBuilder.java} | 13 +-
.../kafka/controller/QuorumControllerTest.java | 146 ++++++++++++++++
.../controller/ReplicationControlManagerTest.java | 11 ++
.../kafka/controller/SnapshotGeneratorTest.java | 110 ++++++++++++
26 files changed, 1234 insertions(+), 100 deletions(-)
copy metadata/src/main/java/org/apache/kafka/{metadata/BrokerRegistrationReply.java => controller/EmptySnapshotReader.java} (65%)
create mode 100644 metadata/src/main/java/org/apache/kafka/controller/SnapshotGenerator.java
copy raft/src/main/java/org/apache/kafka/raft/RaftMessage.java => metadata/src/main/java/org/apache/kafka/controller/SnapshotReader.java (66%)
create mode 100644 metadata/src/main/java/org/apache/kafka/controller/SnapshotWriter.java
copy streams/src/test/java/org/apache/kafka/test/KeyValueIteratorStub.java => metadata/src/test/java/org/apache/kafka/controller/MockSnapshotReader.java (68%)
create mode 100644 metadata/src/test/java/org/apache/kafka/controller/MockSnapshotWriter.java
copy metadata/src/{main/java/org/apache/kafka/metadata/BrokerRegistrationReply.java => test/java/org/apache/kafka/controller/NoOpSnapshotWriter.java} (65%)
copy metadata/src/{main/java/org/apache/kafka/controller/ControllerMetrics.java => test/java/org/apache/kafka/controller/NoOpSnapshotWriterBuilder.java} (78%)
create mode 100644 metadata/src/test/java/org/apache/kafka/controller/SnapshotGeneratorTest.java