You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/02/10 20:46:23 UTC
[kafka] branch trunk updated (ad541b9 -> 06dce72)
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%)