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 ad541b9 MINOR: KafkaBroker.brokerState should be volatile instead of
AtomicReference (#10080)
add 06dce72 MINOR: Rename DecommissionBrokers to UnregisterBrokers
(#10084)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/admin/Admin.java | 31 +++++----
.../kafka/clients/admin/KafkaAdminClient.java | 27 ++++----
...erOptions.java => UnregisterBrokerOptions.java} | 4 +-
...okerResult.java => UnregisterBrokerResult.java} | 6 +-
.../org/apache/kafka/common/protocol/ApiKeys.java | 5 +-
.../org/apache/kafka/common/protocol/Errors.java | 2 +-
.../kafka/common/requests/AbstractRequest.java | 4 +-
.../kafka/common/requests/AbstractResponse.java | 4 +-
...erRequest.java => UnregisterBrokerRequest.java} | 34 +++++-----
...Response.java => UnregisterBrokerResponse.java} | 16 ++---
...erRequest.json => UnregisterBrokerRequest.json} | 4 +-
...Response.json => UnregisterBrokerResponse.json} | 2 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 74 ++++++++++------------
.../kafka/clients/admin/MockAdminClient.java | 6 +-
.../kafka/common/requests/RequestResponseTest.java | 24 +++----
.../scala/kafka/network/RequestConvertToJson.scala | 4 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 10 ++-
core/src/main/scala/kafka/tools/ClusterTool.scala | 23 ++++---
.../scala/unit/kafka/server/RequestQuotaTest.scala | 4 +-
.../scala/unit/kafka/tools/ClusterToolTest.scala | 12 ++--
20 files changed, 151 insertions(+), 145 deletions(-)
rename
clients/src/main/java/org/apache/kafka/clients/admin/{DecommissionBrokerOptions.java
=> UnregisterBrokerOptions.java} (85%)
rename
clients/src/main/java/org/apache/kafka/clients/admin/{DecommissionBrokerResult.java
=> UnregisterBrokerResult.java} (86%)
rename
clients/src/main/java/org/apache/kafka/common/requests/{DecommissionBrokerRequest.java
=> UnregisterBrokerRequest.java} (55%)
rename
clients/src/main/java/org/apache/kafka/common/requests/{DecommissionBrokerResponse.java
=> UnregisterBrokerResponse.java} (73%)
rename
clients/src/main/resources/common/message/{DecommissionBrokerRequest.json =>
UnregisterBrokerRequest.json} (91%)
rename
clients/src/main/resources/common/message/{DecommissionBrokerResponse.json =>
UnregisterBrokerResponse.json} (97%)
