This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 28ef7f1 MINOR: Re-implement NewPartitionReassignment#of() (#7592)
add 1df01d2 KAFKA-9089; Reassignment should be resilient to unexpected
errors (#7562)
No new revisions were added by this update.
Summary of changes:
.../kafka/admin/ReassignPartitionsCommand.scala | 2 +-
.../controller/ControllerChannelManager.scala | 2 +-
.../scala/kafka/controller/ControllerContext.scala | 66 +-
.../src/main/scala/kafka/controller/Election.scala | 8 +-
.../scala/kafka/controller/KafkaController.scala | 714 +++++++++------------
core/src/main/scala/kafka/server/KafkaApis.scala | 4 +-
core/src/main/scala/kafka/zk/AdminZkClient.scala | 11 +-
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 22 +-
core/src/main/scala/kafka/zk/ZkData.scala | 8 +-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 12 +-
.../scala/unit/kafka/admin/DeleteTopicTest.scala | 4 +-
.../admin/ReassignPartitionsClusterTest.scala | 43 +-
.../admin/ReassignPartitionsCommandTest.scala | 4 +-
.../controller/ControllerChannelManagerTest.scala | 2 +-
.../kafka/controller/ControllerContextTest.scala | 34 +-
.../controller/ControllerIntegrationTest.scala | 14 +-
.../controller/PartitionStateMachineTest.scala | 2 +-
.../kafka/controller/ReplicaStateMachineTest.scala | 2 +-
.../kafka/security/auth/ZkAuthorizationTest.scala | 4 +-
.../scala/unit/kafka/zk/AdminZkClientTest.scala | 4 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 8 +-
21 files changed, 428 insertions(+), 542 deletions(-)
