This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch kip1071
in repository https://gitbox.apache.org/repos/asf/kafka.git
from fb2eb8eb8bd Add unit test for StickyTaskAssignor (#18169)
add db1361d065f Add standby task assignment to Streams membership manager
(#18077)
No new revisions were added by this update.
Summary of changes:
.../internals/StreamsMembershipManager.java | 30 +-
.../internals/StreamsMembershipManagerTest.java | 485 ++++++++++++++++-----
.../coordinator/group/GroupCoordinatorConfig.java | 4 +-
.../coordinator/group/GroupCoordinatorShard.java | 5 +-
.../coordinator/group/GroupMetadataManager.java | 78 ++--
.../coordinator/group/streams/StreamsGroup.java | 4 +-
.../group/streams/TargetAssignmentBuilder.java | 11 +-
.../group/taskassignor/StickyTaskAssignor.java | 4 +-
.../group/streams/TargetAssignmentBuilderTest.java | 2 +-
.../group/taskassignor/StickyTaskAssignorTest.java | 25 +-
.../SmokeTestDriverIntegrationTest.java | 2 +-
11 files changed, 478 insertions(+), 172 deletions(-)
