You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2020/05/29 18:25:52 UTC
[kafka] branch trunk updated (9d52dec -> fe948d3)
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 9d52dec KAFKA-9501: convert between active and standby without closing stores (#8248)
add fe948d3 KAFKA-9130; KIP-518 Allow listing consumer groups per state (#8238)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../kafka/clients/admin/ConsumerGroupListing.java | 56 ++++++++++++
.../kafka/clients/admin/KafkaAdminClient.java | 11 ++-
.../clients/admin/ListConsumerGroupsOptions.java | 24 ++++++
.../apache/kafka/common/ConsumerGroupState.java | 1 -
.../kafka/common/requests/ListGroupsRequest.java | 9 ++
.../common/message/ListGroupsRequest.json | 7 +-
.../common/message/ListGroupsResponse.json | 8 +-
.../java/org/apache/kafka/clients/MockClient.java | 16 ++--
.../kafka/clients/admin/KafkaAdminClientTest.java | 88 +++++++++++++++++--
.../kafka/common/requests/RequestResponseTest.java | 46 ++++++----
.../scala/kafka/admin/ConsumerGroupCommand.scala | 99 ++++++++++++++++++----
.../kafka/coordinator/group/GroupCoordinator.scala | 9 +-
.../kafka/coordinator/group/GroupMetadata.scala | 5 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 41 +++++----
.../kafka/api/PlaintextAdminIntegrationTest.scala | 21 ++++-
.../SaslClientsWithInvalidCredentialsTest.scala | 2 +-
.../kafka/admin/DeleteConsumerGroupsTest.scala | 10 +--
.../kafka/admin/DescribeConsumerGroupTest.scala | 44 ++++++++--
.../unit/kafka/admin/ListConsumerGroupTest.scala | 91 +++++++++++++++++++-
.../coordinator/group/GroupCoordinatorTest.scala | 56 ++++++++++--
.../scala/unit/kafka/server/KafkaApisTest.scala | 45 ++++++++++
22 files changed, 598 insertions(+), 93 deletions(-)