This is an automated email from the ASF dual-hosted git repository.
manikumar pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a211ee99b57 KAFKA-17593; [7/N] Introduce CoordinatorExecutor (#17823)
add 32c887b05e0 KAFKA-17949: Introduce GroupState and replace
ShareGroupState (#17763)
No new revisions were added by this update.
Summary of changes:
.../clients/admin/ConsumerGroupDescription.java | 72 ++++-
.../kafka/clients/admin/ConsumerGroupListing.java | 74 ++++-
.../apache/kafka/clients/admin/GroupListing.java | 33 +-
.../kafka/clients/admin/KafkaAdminClient.java | 37 ++-
.../clients/admin/ListConsumerGroupsOptions.java | 32 +-
.../kafka/clients/admin/ListGroupsOptions.java | 19 ++
.../clients/admin/ListShareGroupsOptions.java | 8 +-
.../kafka/clients/admin/ShareGroupDescription.java | 24 +-
.../kafka/clients/admin/ShareGroupListing.java | 20 +-
.../internals/DescribeConsumerGroupsHandler.java | 6 +-
.../internals/DescribeShareGroupsHandler.java | 6 +-
.../apache/kafka/common/ConsumerGroupState.java | 2 +
.../java/org/apache/kafka/common/GroupState.java | 93 ++++++
.../org/apache/kafka/common/ShareGroupState.java | 56 ----
.../kafka/clients/admin/GroupListingTest.java | 9 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 55 ++--
.../kafka/clients/admin/MockAdminClient.java | 3 +-
.../kafka/common/requests/RequestResponseTest.java | 4 +-
.../kafka/connect/mirror/MirrorCheckpointTask.java | 6 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 333 +++++++++++++++++++--
.../server/ShareGroupDescribeRequestTest.scala | 4 +-
.../group/metrics/GroupCoordinatorMetricsTest.java | 8 +-
.../tools/consumer/group/ConsumerGroupCommand.java | 83 ++---
.../{GroupState.java => GroupInformation.java} | 10 +-
.../tools/consumer/group/ShareGroupCommand.java | 69 ++---
.../org/apache/kafka/tools/GroupsCommandTest.java | 41 +--
.../consumer/group/ConsumerGroupServiceTest.java | 20 +-
.../consumer/group/DeleteConsumerGroupsTest.java | 10 +-
.../consumer/group/DescribeConsumerGroupTest.java | 100 +++----
.../consumer/group/ListConsumerGroupTest.java | 124 ++++----
.../group/ResetConsumerGroupOffsetTest.java | 8 +-
.../consumer/group/ShareGroupCommandTest.java | 83 ++---
32 files changed, 988 insertions(+), 464 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/common/GroupState.java
delete mode 100644
clients/src/main/java/org/apache/kafka/common/ShareGroupState.java
rename
tools/src/main/java/org/apache/kafka/tools/consumer/group/{GroupState.java =>
GroupInformation.java} (81%)
