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 e7317b37bf4 KAFKA-17269 Fix ConcurrentModificationException caused by
NioEchoServer.closeNewChannels (#16817)
add 6a44fb154d3 KAFKA-16523; kafka-metadata-quorum: support add-controller
and remove-controller (#16774)
No new revisions were added by this update.
Summary of changes:
build.gradle | 2 +
checkstyle/import-control.xml | 2 +
.../kafka/clients/admin/AddRaftVoterOptions.java | 12 +
.../kafka/clients/admin/KafkaAdminClient.java | 3 +
.../clients/admin/RemoveRaftVoterOptions.java | 12 +
.../org/apache/kafka/common/protocol/ApiKeys.java | 4 +-
.../common/requests/AddRaftVoterResponse.java | 2 +-
.../kafka/common/requests/ApiVersionsRequest.java | 23 +-
.../common/requests/RemoveRaftVoterResponse.java | 2 +-
.../common/message/AddRaftVoterRequest.json | 2 +-
.../common/message/RemoveRaftVoterRequest.json | 2 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 98 ++++++++
core/src/main/scala/kafka/cluster/EndPoint.scala | 41 +---
core/src/main/scala/kafka/tools/StorageTool.scala | 19 +-
core/src/main/scala/kafka/utils/CoreUtils.scala | 6 +-
core/src/main/scala/kafka/zk/ZkData.scala | 21 +-
.../unit/kafka/cluster/BrokerEndPointTest.scala | 41 +---
.../scala/unit/kafka/server/KafkaConfigTest.scala | 2 +-
.../scala/unit/kafka/tools/StorageToolTest.scala | 11 +-
.../java/org/apache/kafka/raft/DynamicVoter.java | 6 +-
.../org/apache/kafka/raft/KafkaNetworkChannel.java | 6 +
.../main/java/org/apache/kafka/raft/RaftUtil.java | 3 +
.../apache/kafka/network/SocketServerConfigs.java | 65 +++++
.../kafka/network/SocketServerConfigsTest.java | 107 +++++++++
.../apache/kafka/tools/MetadataQuorumCommand.java | 220 ++++++++++++++++-
.../tools/MetadataQuorumCommandErrorTest.java | 18 ++
.../kafka/tools/MetadataQuorumCommandUnitTest.java | 264 +++++++++++++++++++++
27 files changed, 873 insertions(+), 121 deletions(-)
create mode 100644
server/src/test/java/org/apache/kafka/network/SocketServerConfigsTest.java
create mode 100644
tools/src/test/java/org/apache/kafka/tools/MetadataQuorumCommandUnitTest.java
