You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2024/02/01 08:31:02 UTC
(kafka) branch trunk updated (af41fc36148 -> 6c09cc9586f)
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 af41fc36148 KAFKA-16168; Implement GroupCoordinator.onPartitionsDeleted (#15237)
add 6c09cc9586f KAFKA-16189; Extend admin to support ConsumerGroupDescribe API (#15253)
No new revisions were added by this update.
Summary of changes:
.../clients/admin/ConsumerGroupDescription.java | 26 ++-
.../kafka/clients/admin/MemberDescription.java | 46 +++-
.../internals/DescribeConsumerGroupsHandler.java | 220 ++++++++++++++++--
.../common/requests/FindCoordinatorResponse.java | 23 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 183 ++++++++++++++-
.../DescribeConsumerGroupsHandlerTest.java | 253 ++++++++++++++++++---
.../scala/kafka/admin/ConsumerGroupCommand.scala | 2 +-
.../kafka/admin/ConsumerGroupCommandTest.scala | 38 +++-
.../kafka/admin/DescribeConsumerGroupTest.scala | 248 ++++++++++----------
9 files changed, 837 insertions(+), 202 deletions(-)