This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 43262d3 KAFKA-9038; Allow creating partitions while a reassignment is
in progress (#7582)
add 77fc498 KAFKA-8992; Redefine RemoveMembersFromGroup interface on
AdminClient (#7478)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/admin/Admin.java | 2 +-
.../admin/DeleteConsumerGroupOffsetsResult.java | 65 +++++----
.../kafka/clients/admin/KafkaAdminClient.java | 77 ++++++-----
.../admin/MemberToRemove.java} | 50 +++----
.../clients/admin/MembershipChangeResult.java | 49 -------
.../RemoveMemberFromConsumerGroupOptions.java | 50 -------
.../clients/admin/RemoveMemberFromGroupResult.java | 85 ------------
... => RemoveMembersFromConsumerGroupOptions.java} | 24 ++--
.../RemoveMembersFromConsumerGroupResult.java | 96 +++++++++++++
.../kafka/common/requests/LeaveGroupRequest.java | 6 +-
.../DeleteConsumerGroupOffsetsResultTest.java | 118 ++++++++++++++++
.../kafka/clients/admin/KafkaAdminClientTest.java | 138 +++++++++---------
.../clients/admin/MembershipChangeResultTest.java | 50 -------
.../kafka/clients/admin/MockAdminClient.java | 2 +-
.../admin/RemoveMemberFromGroupResultTest.java | 154 ---------------------
...RemoveMembersFromConsumerGroupOptionsTest.java} | 13 +-
.../RemoveMembersFromConsumerGroupResultTest.java | 119 ++++++++++++++++
.../scala/kafka/admin/ConsumerGroupCommand.scala | 68 +++++----
.../kafka/api/AdminClientIntegrationTest.scala | 61 +++-----
.../kafka/api/AuthorizerIntegrationTest.scala | 2 +-
...ffsetsConsumerGroupCommandIntegrationTest.scala | 18 ++-
21 files changed, 603 insertions(+), 644 deletions(-)
copy
clients/src/main/java/org/apache/kafka/{common/protocol/types/RawTaggedField.java
=> clients/admin/MemberToRemove.java} (50%)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/MembershipChangeResult.java
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMemberFromConsumerGroupOptions.java
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMemberFromGroupResult.java
copy
clients/src/main/java/org/apache/kafka/clients/admin/{ListOffsetsOptions.java
=> RemoveMembersFromConsumerGroupOptions.java} (62%)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResultTest.java
delete mode 100644
clients/src/test/java/org/apache/kafka/clients/admin/MembershipChangeResultTest.java
delete mode 100644
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMemberFromGroupResultTest.java
rename
clients/src/test/java/org/apache/kafka/clients/admin/{RemoveMemberFromConsumerGroupOptionsTest.java
=> RemoveMembersFromConsumerGroupOptionsTest.java} (66%)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResultTest.java
