This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e31d3d4 MINOR: Add HostedPartition.Deferred state in ReplicaManager
(#10003)
add 3f36f9a KAFKA-12249: Add client-side Decommission Broker RPC
(KIP-500) (#9996)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/admin/Admin.java | 37 +++++++
...Options.java => DecommissionBrokerOptions.java} | 5 +-
...esResult.java => DecommissionBrokerResult.java} | 15 +--
.../kafka/clients/admin/KafkaAdminClient.java | 44 +++++++++
.../org/apache/kafka/common/protocol/ApiKeys.java | 6 +-
.../kafka/common/requests/AbstractRequest.java | 2 +
.../kafka/common/requests/AbstractResponse.java | 2 +
...Request.java => DecommissionBrokerRequest.java} | 39 ++++----
...sponse.java => DecommissionBrokerResponse.java} | 25 +++--
.../common/message/DecommissionBrokerRequest.json | 11 +--
...sponse.json => DecommissionBrokerResponse.json} | 8 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 109 +++++++++++++++++++++
.../kafka/clients/admin/MockAdminClient.java | 5 +
.../kafka/common/requests/RequestResponseTest.java | 55 ++++++++---
.../scala/kafka/network/RequestConvertToJson.scala | 2 +
core/src/main/scala/kafka/server/KafkaApis.scala | 1 +
.../scala/unit/kafka/server/RequestQuotaTest.scala | 3 +
17 files changed, 302 insertions(+), 67 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DescribeFeaturesOptions.java
=> DecommissionBrokerOptions.java} (85%)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DescribeFeaturesResult.java
=> DecommissionBrokerResult.java} (74%)
copy
clients/src/main/java/org/apache/kafka/common/requests/{BrokerRegistrationRequest.java
=> DecommissionBrokerRequest.java} (56%)
copy
clients/src/main/java/org/apache/kafka/common/requests/{BrokerRegistrationResponse.java
=> DecommissionBrokerResponse.java} (69%)
copy metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json
=> clients/src/main/resources/common/message/DecommissionBrokerRequest.json
(81%)
copy
clients/src/main/resources/common/message/{BrokerRegistrationResponse.json =>
DecommissionBrokerResponse.json} (83%)
