This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from e0c77140b2c KAFKA-17039 KIP-919 supports for unregisterBroker (#19063)
add 3c73c9bdc19 MINOR: Clean up group-coordinator (#19008)
No new revisions were added by this update.
Summary of changes:
.../group/GroupCoordinatorRecordHelpers.java | 2 +-
.../coordinator/group/GroupCoordinatorService.java | 21 +-
.../coordinator/group/GroupMetadataManager.java | 88 ++---
.../coordinator/group/OffsetMetadataManager.java | 3 +-
.../coordinator/group/assignor/RangeAssignor.java | 3 +-
.../coordinator/group/assignor/SimpleAssignor.java | 3 +-
.../group/assignor/UniformAssignor.java | 4 +-
.../UniformHeterogeneousAssignmentBuilder.java | 3 +-
.../UniformHomogeneousAssignmentBuilder.java | 3 +-
.../coordinator/group/classic/ClassicGroup.java | 7 +-
.../group/classic/ClassicGroupMember.java | 3 +-
.../group/metrics/GroupCoordinatorMetrics.java | 28 +-
.../metrics/GroupCoordinatorMetricsShard.java | 9 +-
.../kafka/coordinator/group/modern/Assignment.java | 2 +-
.../coordinator/group/modern/GroupSpecImpl.java | 3 +-
.../coordinator/group/modern/ModernGroup.java | 6 +-
.../group/modern/SubscribedTopicDescriberImpl.java | 3 +-
.../group/modern/TargetAssignmentBuilder.java | 10 +-
.../group/modern/consumer/ConsumerGroup.java | 4 +-
.../group/modern/consumer/ConsumerGroupMember.java | 9 +-
.../modern/consumer/CurrentAssignmentBuilder.java | 13 +-
.../modern/consumer/ResolvedRegularExpression.java | 2 +-
.../group/modern/share/ShareGroupMember.java | 5 +-
.../group/streams/CurrentAssignmentBuilder.java | 5 +-
.../streams/StreamsCoordinatorRecordHelpers.java | 11 +-
.../coordinator/group/streams/StreamsGroup.java | 8 +-
.../group/streams/StreamsGroupMember.java | 2 +-
.../coordinator/group/streams/TasksTuple.java | 6 +-
.../group/streams/assignor/MemberAssignment.java | 3 +-
.../streams/topics/ConfiguredInternalTopic.java | 12 +-
.../streams/topics/ConfiguredSubtopology.java | 9 +-
.../group/streams/topics/ConfiguredTopology.java | 5 +-
.../topics/CopartitionedTopicsEnforcer.java | 3 +-
.../group/streams/topics/InternalTopicManager.java | 5 +-
.../apache/kafka/coordinator/group/Assertions.java | 5 +-
.../group/GroupCoordinatorConfigTest.java | 7 +-
.../group/GroupCoordinatorRecordHelpersTest.java | 7 +-
.../group/GroupCoordinatorServiceTest.java | 155 ++++----
.../group/GroupCoordinatorShardTest.java | 21 +-
.../group/GroupMetadataManagerTest.java | 423 ++++++++++-----------
.../group/GroupMetadataManagerTestContext.java | 12 +-
.../group/OffsetMetadataManagerTest.java | 245 ++++++------
.../group/assignor/GroupSpecImplTest.java | 3 +-
.../OptimizedUniformAssignmentBuilderTest.java | 37 +-
.../group/assignor/RangeAssignorTest.java | 39 +-
.../UniformHeterogeneousAssignmentBuilderTest.java | 47 ++-
.../group/classic/ClassicGroupTest.java | 13 +-
.../group/metrics/GroupCoordinatorMetricsTest.java | 50 +--
.../group/modern/TargetAssignmentBuilderTest.java | 11 +-
.../coordinator/group/modern/TopicIdsTest.java | 11 +-
.../coordinator/group/modern/UnionSetTest.java | 13 +-
.../modern/consumer/ConsumerGroupMemberTest.java | 18 +-
.../group/modern/consumer/ConsumerGroupTest.java | 83 ++--
.../consumer/CurrentAssignmentBuilderTest.java | 6 +-
.../group/modern/share/ShareGroupMemberTest.java | 5 +-
.../group/modern/share/ShareGroupTest.java | 62 +--
.../streams/CurrentAssignmentBuilderTest.java | 70 ++--
.../group/streams/StreamsGroupMemberTest.java | 2 +-
.../group/streams/StreamsGroupTest.java | 109 +++---
.../group/streams/TargetAssignmentBuilderTest.java | 5 +-
.../coordinator/group/streams/TasksTupleTest.java | 13 +-
.../group/streams/assignor/GroupSpecImplTest.java | 13 +-
.../group/streams/assignor/MockAssignorTest.java | 93 +++--
.../streams/assignor/StickyTaskAssignorTest.java | 211 +++++-----
.../group/streams/topics/ChangelogTopicsTest.java | 29 +-
.../topics/ConfiguredInternalTopicTest.java | 7 +-
.../streams/topics/ConfiguredSubtopologyTest.java | 25 +-
.../streams/topics/ConfiguredTopologyTest.java | 9 +-
.../topics/CopartitionedTopicsEnforcerTest.java | 3 +-
.../streams/topics/InternalTopicManagerTest.java | 28 +-
.../streams/topics/RepartitionTopicsTest.java | 3 +-
71 files changed, 1072 insertions(+), 1124 deletions(-)
