This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 69645f1 KAFKA-13495: Add reason to JoinGroupRequest (KIP-800) (#11566)
add bf60969 KAFKA-13496: Add reason to LeaveGroupRequest (KIP-800)
(#11571)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 9 ++++
.../RemoveMembersFromConsumerGroupOptions.java | 12 ++++++
.../consumer/internals/AbstractCoordinator.java | 2 +-
.../common/message/LeaveGroupRequest.json | 9 +++-
.../common/message/LeaveGroupResponse.json | 4 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 50 ++++++++++++++++++++++
.../internals/AbstractCoordinatorTest.java | 10 ++++-
.../kafka/common/requests/RequestResponseTest.java | 6 ++-
.../kafka/coordinator/group/GroupCoordinator.scala | 12 +++---
9 files changed, 103 insertions(+), 11 deletions(-)