kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated (41b89a6 -> 18d4e57)
Date Wed, 11 Sep 2019 05:20:16 GMT
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 41b89a6  MINOR: Add api version to uncaught exception message (#7311)
     add 18d4e57  KAFKA-8345 (KIP-455): Controller and KafkaApi changes (part 3/4) (#7128)

No new revisions were added by this update.

Summary of changes:
 core/src/main/scala/kafka/admin/TopicCommand.scala |   9 +-
 .../controller/ControllerChannelManager.scala      |   6 +-
 .../scala/kafka/controller/ControllerContext.scala | 106 ++-
 .../scala/kafka/controller/ControllerState.scala   |  10 +-
 .../scala/kafka/controller/KafkaController.scala   | 608 +++++++++++++----
 .../kafka/controller/PartitionStateMachine.scala   |   9 +-
 .../kafka/controller/ReplicaStateMachine.scala     |   6 +-
 .../src/main/scala/kafka/server/AdminManager.scala |   8 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  86 ++-
 core/src/main/scala/kafka/zk/AdminZkClient.scala   |  20 +-
 core/src/main/scala/kafka/zk/KafkaZkClient.scala   |  37 +-
 core/src/main/scala/kafka/zk/ZkData.scala          |  62 +-
 .../kafka/api/AdminClientIntegrationTest.scala     |  52 ++
 .../kafka/api/BaseProducerSendTest.scala           |   4 +-
 .../other/kafka/ReplicationQuotasTestRig.scala     |   4 +-
 .../scala/unit/kafka/admin/AddPartitionsTest.scala |  19 +-
 .../scala/unit/kafka/admin/DeleteTopicTest.scala   |   9 +-
 .../admin/ReassignPartitionsClusterTest.scala      | 726 +++++++++++++++++++--
 .../controller/ControllerChannelManagerTest.scala  |  12 +-
 .../kafka/controller/ControllerContextTest.scala   | 189 ++++++
 .../controller/ControllerIntegrationTest.scala     |  22 +-
 .../controller/PartitionStateMachineTest.scala     |  13 +-
 .../kafka/controller/ReplicaStateMachineTest.scala |  11 +-
 .../kafka/security/auth/ZkAuthorizationTest.scala  |   3 +-
 .../scala/unit/kafka/zk/AdminZkClientTest.scala    |   8 +-
 .../scala/unit/kafka/zk/KafkaZkClientTest.scala    |   6 +-
 docs/upgrade.html                                  |   2 +
 27 files changed, 1721 insertions(+), 326 deletions(-)
 create mode 100644 core/src/test/scala/unit/kafka/controller/ControllerContextTest.scala


Mime
View raw message