[kafka] branch trunk updated (43bf464 -> 5262161)

[js...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

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


    from 43bf464  KAFKA-13497: Add trace logging to RegexRouter (#11903)
     add 5262161  KAFKA-13587; Implement leader recovery for KIP-704 (#11733)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   2 +-
 .../kafka/common/requests/AbstractRequest.java     |   4 +-
 .../kafka/common/requests/AbstractResponse.java    |   4 +-
 ...rIsrRequest.java => AlterPartitionRequest.java} |  32 +--
 ...srResponse.java => AlterPartitionResponse.java} |  16 +-
 ...rIsrRequest.json => AlterPartitionRequest.json} |  12 +-
 ...srResponse.json => AlterPartitionResponse.json} |  12 +-
 .../common/message/LeaderAndIsrRequest.json        |   8 +-
 .../common/message/LeaderAndIsrResponse.json       |   4 +-
 .../apache/kafka/common/protocol/ApiKeysTest.java  |   4 +-
 .../kafka/common/requests/RequestResponseTest.java |  66 +++---
 core/src/main/scala/kafka/api/ApiVersion.scala     |  13 +-
 core/src/main/scala/kafka/api/LeaderAndIsr.scala   |  26 ++-
 core/src/main/scala/kafka/cluster/Partition.scala  | 186 +++++++++-------
 .../controller/ControllerChannelManager.scala      |  13 +-
 .../src/main/scala/kafka/controller/Election.scala |  20 +-
 .../scala/kafka/controller/KafkaController.scala   | 115 ++++++----
 .../kafka/controller/PartitionStateMachine.scala   |  10 +-
 .../scala/kafka/network/RequestConvertToJson.scala |   4 +-
 .../main/scala/kafka/server/AlterIsrManager.scala  | 110 ++++++----
 .../src/main/scala/kafka/server/BrokerServer.scala |   3 +-
 .../main/scala/kafka/server/ControllerApis.scala   |  12 +-
 .../main/scala/kafka/server/ControllerServer.scala |   2 +
 core/src/main/scala/kafka/server/KafkaApis.scala   |  12 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |   6 +-
 .../main/scala/kafka/server/ReplicaManager.scala   |   1 -
 core/src/main/scala/kafka/zk/ZkData.scala          |  31 ++-
 core/src/test/java/kafka/test/MockController.java  |   6 +-
 .../api/LeaderAndIsrTest.scala}                    |  24 +--
 .../kafka/zk/TopicPartitionStateZNodeTest.scala    |  74 +++++++
 .../test/scala/unit/kafka/api/ApiVersionTest.scala |   4 +
 .../scala/unit/kafka/cluster/PartitionTest.scala   | 157 +++++++++-----
 .../controller/ControllerChannelManagerTest.scala  |  36 +++-
 .../controller/ControllerIntegrationTest.scala     |  39 ++--
 .../controller/MockPartitionStateMachine.scala     |  14 +-
 .../controller/PartitionStateMachineTest.scala     |  39 +++-
 .../controller/TopicDeletionManagerTest.scala      |  24 ++-
 .../kafka/network/RequestConvertToJsonTest.scala   |   6 +-
 .../unit/kafka/server/AlterIsrManagerTest.scala    | 179 ++++++++++------
 .../unit/kafka/server/ControllerApisTest.scala     |   6 +-
 .../server/HighwatermarkPersistenceTest.scala      |   4 +-
 .../unit/kafka/server/IsrExpirationTest.scala      |   4 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |   4 +-
 .../server/ReplicaManagerConcurrencyTest.scala     |  10 +-
 .../kafka/server/ReplicaManagerQuotasTest.scala    |   8 +-
 .../unit/kafka/server/ReplicaManagerTest.scala     |   2 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   4 +-
 .../metadata/BrokerMetadataPublisherTest.scala     |   6 +-
 .../unit/kafka/utils/ReplicationUtilsTest.scala    |   9 +-
 .../scala/unit/kafka/zk/KafkaZkClientTest.scala    |  44 ++--
 .../org/apache/kafka/controller/Controller.java    |  10 +-
 .../kafka/controller/PartitionChangeBuilder.java   |  23 +-
 .../apache/kafka/controller/QuorumController.java  |  25 ++-
 .../controller/ReplicationControlManager.java      | 236 +++++++++++++--------
 .../apache/kafka/metadata/LeaderRecoveryState.java |  74 +++++++
 .../kafka/metadata/PartitionRegistration.java      |  23 +-
 .../common/metadata/PartitionChangeRecord.json     |   4 +-
 .../resources/common/metadata/PartitionRecord.json |   2 +
 .../controller/PartitionChangeBuilderTest.java     | 129 ++++++++++-
 .../PartitionReassignmentRevertTest.java           |  11 +-
 .../kafka/controller/QuorumControllerTest.java     |  20 +-
 .../controller/ReplicationControlManagerTest.java  | 208 ++++++++++--------
 .../org/apache/kafka/image/TopicsImageTest.java    |  15 +-
 .../kafka/metadata/LeaderRecoveryStateTest.java    |  87 ++++++++
 .../kafka/metadata/PartitionRegistrationTest.java  |  18 +-
 65 files changed, 1594 insertions(+), 722 deletions(-)
 rename clients/src/main/java/org/apache/kafka/common/requests/{AlterIsrRequest.java => AlterPartitionRequest.java} (62%)
 rename clients/src/main/java/org/apache/kafka/common/requests/{AlterIsrResponse.java => AlterPartitionResponse.java} (75%)
 rename clients/src/main/resources/common/message/{AlterIsrRequest.json => AlterPartitionRequest.json} (77%)
 rename clients/src/main/resources/common/message/{AlterIsrResponse.json => AlterPartitionResponse.json} (81%)
 copy core/src/test/scala/{unit/kafka/utils/PoolTest.scala => kafka/api/LeaderAndIsrTest.scala} (65%)
 create mode 100644 core/src/test/scala/kafka/zk/TopicPartitionStateZNodeTest.scala
 create mode 100644 metadata/src/main/java/org/apache/kafka/metadata/LeaderRecoveryState.java
 create mode 100644 metadata/src/test/java/org/apache/kafka/metadata/LeaderRecoveryStateTest.java