This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 41442903352 MINOR: Cleanup metadata module (#18937)
add 6d72677eda3 KAFKA-18613: Add StreamsGroupHeartbeat handler in the
group coordinator (#19114)
No new revisions were added by this update.
Summary of changes:
.../coordinator/group/GroupCoordinatorShard.java | 2 +-
.../coordinator/group/GroupMetadataManager.java | 846 +++++++-
.../group/streams/CurrentAssignmentBuilder.java | 2 +-
.../coordinator/group/streams/StreamsGroup.java | 56 +-
.../group/streams/StreamsGroupMember.java | 15 +
.../coordinator/group/streams/StreamsTopology.java | 14 +
.../coordinator/group/streams/TasksTuple.java | 71 +-
.../group/streams/assignor/MemberAssignment.java | 4 +-
.../group/GroupMetadataManagerTest.java | 2094 +++++++++++++++++++-
.../group/GroupMetadataManagerTestContext.java | 49 +
.../group/streams/MockTaskAssignor.java | 65 +
.../group/streams/StreamsGroupBuilder.java | 4 +-
.../group/streams/StreamsGroupTest.java | 52 +-
.../group/streams/StreamsTopologyTest.java | 62 +
14 files changed, 3252 insertions(+), 84 deletions(-)
create mode 100644
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/MockTaskAssignor.java
