kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [kafka] branch trunk updated (e7ce0e7 -> 2155c6d)
Date Mon, 03 Dec 2018 06:00:58 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from e7ce0e7  KAFKA-4544: Add system tests for delegation token based authentication
     add 2155c6d  KAFKA-7235: Detect outdated control requests and bounced brokers using broker
generation (#5821)

No new revisions were added by this update.

Summary of changes:
 ...ception.java => StaleBrokerEpochException.java} |   6 +-
 .../org/apache/kafka/common/protocol/Errors.java   |   5 +-
 .../apache/kafka/common/protocol/types/Struct.java |  12 +-
 .../common/requests/AbstractControlRequest.java    |  80 ++++
 .../common/requests/ControlledShutdownRequest.java |  27 +-
 .../requests/ControlledShutdownResponse.java       |   3 +-
 .../kafka/common/requests/LeaderAndIsrRequest.java | 299 ++++++++------
 .../common/requests/LeaderAndIsrResponse.java      |  18 +-
 .../kafka/common/requests/StopReplicaRequest.java  | 133 +++---
 .../kafka/common/requests/StopReplicaResponse.java |  19 +-
 .../common/requests/UpdateMetadataRequest.java     | 455 +++++++++++----------
 .../common/requests/UpdateMetadataResponse.java    |   4 +-
 .../apache/kafka/common/utils/CollectionUtils.java |   3 +-
 .../kafka/common/requests/ControlRequestTest.java  |  87 ++++
 .../common/requests/LeaderAndIsrResponseTest.java  |   2 +-
 .../kafka/common/requests/RequestResponseTest.java |  35 +-
 .../common/requests/StopReplicaResponseTest.java   |   3 +-
 core/src/main/scala/kafka/api/ApiVersion.scala     |  12 +-
 .../controller/ControllerChannelManager.scala      | 105 ++---
 .../scala/kafka/controller/ControllerContext.scala |  33 +-
 .../scala/kafka/controller/KafkaController.scala   |  80 +++-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  57 ++-
 core/src/main/scala/kafka/server/KafkaServer.scala |  14 +-
 .../main/scala/kafka/server/ReplicaManager.scala   |   2 +-
 core/src/main/scala/kafka/zk/KafkaZkClient.scala   | 293 +++++++------
 .../scala/kafka/zookeeper/ZooKeeperClient.scala    | 158 ++++---
 .../kafka/api/AuthorizerIntegrationTest.scala      |  10 +-
 .../controller/ControllerIntegrationTest.scala     |  72 +++-
 .../controller/PartitionStateMachineTest.scala     |  20 +-
 .../kafka/server/BrokerEpochIntegrationTest.scala  | 242 +++++++++++
 .../scala/unit/kafka/server/KafkaApisTest.scala    |   4 +-
 .../unit/kafka/server/LeaderElectionTest.scala     |  11 +-
 .../unit/kafka/server/MetadataCacheTest.scala      |  13 +-
 .../unit/kafka/server/ReplicaManagerTest.scala     |  18 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   8 +-
 .../unit/kafka/server/ServerShutdownTest.scala     |   6 +-
 .../unit/kafka/server/StopReplicaRequestTest.scala |   5 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |   5 +
 .../scala/unit/kafka/zk/KafkaZkClientTest.scala    |  36 +-
 39 files changed, 1599 insertions(+), 796 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/errors/{InvalidFetchSizeException.java
=> StaleBrokerEpochException.java} (84%)
 create mode 100644 clients/src/main/java/org/apache/kafka/common/requests/AbstractControlRequest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/ControlRequestTest.java
 create mode 100755 core/src/test/scala/unit/kafka/server/BrokerEpochIntegrationTest.scala


Mime
View raw message