kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (312e4db -> e59e4ca)
Date Mon, 09 Sep 2019 20:07:35 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 312e4db  MINOR. implement --expose-ports option in ducker-ak (#7269)
     add e59e4ca  KAFKA-8222 & KIP-345 part 5: admin request to batch remove members (#7122)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/clients/admin/Admin.java |  12 ++
 .../kafka/clients/admin/KafkaAdminClient.java      |  67 ++++++++-
 ...AclsResult.java => MembershipChangeResult.java} |  25 ++--
 .../RemoveMemberFromConsumerGroupOptions.java      |  50 +++++++
 .../clients/admin/RemoveMemberFromGroupResult.java |  85 ++++++++++++
 .../kafka/common/requests/LeaveGroupResponse.java  |   4 +
 .../common/message/LeaveGroupResponse.json         |   2 +-
 .../kafka/clients/admin/KafkaAdminClientTest.java  | 133 ++++++++++++++++--
 .../clients/admin/MembershipChangeResultTest.java  |  50 +++++++
 .../kafka/clients/admin/MockAdminClient.java       |   5 +
 .../RemoveMemberFromConsumerGroupOptionsTest.java  |  21 ++-
 .../admin/RemoveMemberFromGroupResultTest.java     | 154 +++++++++++++++++++++
 .../kafka/api/AdminClientIntegrationTest.scala     |  85 ++++++++++--
 13 files changed, 652 insertions(+), 41 deletions(-)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{DescribeAclsResult.java =>
MembershipChangeResult.java} (60%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/RemoveMemberFromConsumerGroupOptions.java
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/RemoveMemberFromGroupResult.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/MembershipChangeResultTest.java
 copy connect/api/src/test/java/org/apache/kafka/connect/storage/ConverterTypeTest.java =>
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMemberFromConsumerGroupOptionsTest.java
(59%)
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/RemoveMemberFromGroupResultTest.java


Mime
View raw message