[kafka] branch trunk updated (d3612eb -> 5eac5a8)

[cm...@apache.org]

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 d3612eb  KAFKA-9672: Leader with ISR as a superset of replicas (#9631)
     add 5eac5a8  KAFKA-12276: Add the quorum controller code (#10070)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |   1 +
 checkstyle/import-control.xml                      |   2 +
 checkstyle/suppressions.xml                        |   6 +
 ...on.java => BrokerIdNotRegisteredException.java} |   9 +-
 .../org/apache/kafka/common/protocol/Errors.java   |   6 +-
 .../kafka/common/requests/RequestResponseTest.java |   1 -
 .../src/main/scala/kafka/server/BrokerServer.scala |   3 +
 .../main/scala/kafka/server/ControllerApis.scala   |   2 +-
 .../main/scala/kafka/server/ControllerServer.scala |  25 +-
 .../server/metadata/BrokerMetadataListener.scala   |  10 +-
 .../kafka/server/metadata/MetadataPartitions.scala |  26 +-
 .../kafka/controller/BrokerControlState.java       |  35 +-
 .../BrokerControlStates.java}                      |  40 +-
 .../kafka/controller/BrokerHeartbeatManager.java   | 597 +++++++++++++
 .../org/apache/kafka/controller/BrokersToIsrs.java | 314 +++++++
 .../controller/ClientQuotaControlManager.java      | 275 ++++++
 .../kafka/controller/ClusterControlManager.java    | 346 ++++++++
 .../controller/ConfigurationControlManager.java    | 367 ++++++++
 .../org/apache/kafka/controller/Controller.java    |  17 +-
 .../apache/kafka/controller/ControllerMetrics.java |  12 +-
 .../kafka/controller/ControllerPurgatory.java      | 108 +++
 .../{ResultOrError.java => ControllerResult.java}  |  65 +-
 ...OrError.java => ControllerResultAndOffset.java} |  63 +-
 .../Delta.java => controller/DeferredEvent.java}   |  14 +-
 .../kafka/controller/FeatureControlManager.java    | 136 +++
 .../apache/kafka/controller/QuorumController.java  | 941 +++++++++++++++++++++
 .../kafka/controller/QuorumControllerMetrics.java  |  70 ++
 .../kafka/controller/ReplicaPlacementPolicy.java   |  47 +
 .../java/org/apache/kafka/controller/Replicas.java | 180 ++++
 .../controller/ReplicationControlManager.java      | 908 ++++++++++++++++++++
 .../org/apache/kafka/controller/ResultOrError.java |   4 +-
 .../controller/SimpleReplicaPlacementPolicy.java   |  77 ++
 .../kafka/metadata/BrokerHeartbeatReply.java       |  15 +-
 ...kerRegistrationReply.java => UsableBroker.java} |  37 +-
 .../common/metadata/AccessControlRecord.json       |   1 +
 ...hangeRecord.json => PartitionChangeRecord.json} |  17 +-
 .../resources/common/metadata/PartitionRecord.json |   2 +-
 .../controller/BrokerHeartbeatManagerTest.java     | 296 +++++++
 .../apache/kafka/controller/BrokersToIsrsTest.java | 109 +++
 .../controller/ClientQuotaControlManagerTest.java  | 238 ++++++
 .../controller/ClusterControlManagerTest.java      | 150 ++++
 .../ConfigurationControlManagerTest.java           | 203 +++++
 .../kafka/controller/ControllerPurgatoryTest.java  | 102 +++
 .../kafka/controller/ControllerTestUtils.java      |  51 ++
 .../controller/FeatureControlManagerTest.java      | 132 +++
 .../kafka/controller/MockControllerMetrics.java    |  29 +-
 .../org/apache/kafka/controller/MockRandom.java    |  19 +-
 .../kafka/controller/QuorumControllerTest.java     | 180 ++++
 .../kafka/controller/QuorumControllerTestEnv.java  |  88 ++
 .../org/apache/kafka/controller/ReplicasTest.java  |  96 +++
 .../controller/ReplicationControlManagerTest.java  | 204 +++++
 .../apache/kafka/controller/ResultOrErrorTest.java |  65 ++
 .../org/apache/kafka/metalog/LocalLogManager.java  |  43 +
 .../apache/kafka/metalog/LocalLogManagerTest.java  |   1 +
 .../apache/kafka/shell/MetadataNodeManager.java    |  20 +-
 55 files changed, 6596 insertions(+), 209 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/errors/{InconsistentClusterIdException.java => BrokerIdNotRegisteredException.java} (83%)
 copy clients/src/main/java/org/apache/kafka/common/errors/RecordBatchTooLargeException.java => metadata/src/main/java/org/apache/kafka/controller/BrokerControlState.java (57%)
 copy metadata/src/main/java/org/apache/kafka/{metalog/MetaLogLeader.java => controller/BrokerControlStates.java} (58%)
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/BrokersToIsrs.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/ClientQuotaControlManager.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java
 copy streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java => metadata/src/main/java/org/apache/kafka/controller/ControllerMetrics.java (77%)
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/ControllerPurgatory.java
 copy metadata/src/main/java/org/apache/kafka/controller/{ResultOrError.java => ControllerResult.java} (50%)
 copy metadata/src/main/java/org/apache/kafka/controller/{ResultOrError.java => ControllerResultAndOffset.java} (50%)
 copy metadata/src/main/java/org/apache/kafka/{timeline/Delta.java => controller/DeferredEvent.java} (71%)
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/QuorumControllerMetrics.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/ReplicaPlacementPolicy.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/Replicas.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
 create mode 100644 metadata/src/main/java/org/apache/kafka/controller/SimpleReplicaPlacementPolicy.java
 copy metadata/src/main/java/org/apache/kafka/metadata/{BrokerRegistrationReply.java => UsableBroker.java} (61%)
 rename metadata/src/main/resources/common/metadata/{IsrChangeRecord.json => PartitionChangeRecord.json} (63%)
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/BrokerHeartbeatManagerTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/BrokersToIsrsTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ClientQuotaControlManagerTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ClusterControlManagerTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ConfigurationControlManagerTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ControllerPurgatoryTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ControllerTestUtils.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java
 copy clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenMock.java => metadata/src/test/java/org/apache/kafka/controller/MockControllerMetrics.java (63%)
 copy tools/src/main/java/org/apache/kafka/trogdor/workload/NullPayloadGenerator.java => metadata/src/test/java/org/apache/kafka/controller/MockRandom.java (70%)
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTestEnv.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ReplicasTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/controller/ResultOrErrorTest.java