This is an automated email from the ASF dual-hosted git repository.
payang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 44c6e956ed3 KAFKA-19529: State updater sensor names should be unique
(#20262)
add fd9b5514add MINOR: Cleanups in coordinator-common/group-coordinator
(#20097)
No new revisions were added by this update.
Summary of changes:
.../CoordinatorOperationExceptionHelper.java | 39 ++++-------
.../common/runtime/MockCoordinatorExecutor.java | 23 +------
.../common/runtime/MockCoordinatorShard.java | 2 +-
.../common/runtime/MockCoordinatorTimer.java | 46 +------------
.../coordinator/group/GroupCoordinatorConfig.java | 2 +-
.../group/GroupCoordinatorRecordHelpers.java | 6 +-
.../coordinator/group/GroupCoordinatorService.java | 46 ++++++-------
.../coordinator/group/GroupMetadataManager.java | 6 +-
.../group/OffsetExpirationConditionImpl.java | 25 ++-----
.../coordinator/group/OffsetMetadataManager.java | 2 +-
.../group/ShareGroupAutoOffsetResetStrategy.java | 20 ++----
.../UniformHeterogeneousAssignmentBuilder.java | 2 +-
.../UniformHomogeneousAssignmentBuilder.java | 12 +---
.../coordinator/group/classic/ClassicGroup.java | 5 +-
.../metrics/GroupCoordinatorMetricsShard.java | 15 +---
.../group/modern/MemberAssignmentImpl.java | 27 ++------
.../coordinator/group/modern/ModernGroup.java | 2 +-
.../group/modern/SubscriptionCount.java | 27 +-------
.../group/modern/TargetAssignmentBuilder.java | 6 +-
.../kafka/coordinator/group/modern/TopicIds.java | 12 +---
.../group/modern/consumer/ConsumerGroup.java | 16 ++---
.../modern/consumer/ResolvedRegularExpression.java | 51 ++------------
.../group/streams/StreamsGroupHeartbeatResult.java | 2 +-
.../group/streams/TopologyMetadata.java | 4 +-
.../group/streams/assignor/StickyTaskAssignor.java | 2 +-
.../apache/kafka/coordinator/group/Assertions.java | 12 ++--
.../group/GroupCoordinatorConfigTest.java | 19 +++--
.../group/GroupCoordinatorShardTest.java | 4 +-
.../group/GroupMetadataManagerTest.java | 80 +++++++++++-----------
.../group/GroupMetadataManagerTestContext.java | 22 +++---
.../group/OffsetMetadataManagerTest.java | 23 ++-----
.../coordinator/group/assignor/RangeSetTest.java | 6 +-
.../group/classic/ClassicGroupTest.java | 4 +-
.../group/modern/TargetAssignmentBuilderTest.java | 6 +-
.../group/modern/consumer/ConsumerGroupTest.java | 6 +-
.../consumer/ResolvedRegularExpressionTest.java | 6 +-
.../group/modern/share/ShareGroupTest.java | 6 +-
.../streams/assignor/StickyTaskAssignorTest.java | 16 +----
.../streams/topics/ConfiguredTopologyTest.java | 2 +-
39 files changed, 191 insertions(+), 421 deletions(-)
