This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from be80e3cb8a0 KAFKA-18923: resource leak in RSM fetchIndex inputStream
(#19111)
add 37f7434eac6 KAFKA-18827: Incorporate initializing topics in share
group heartbeat [4/N] (#19339)
No new revisions were added by this update.
Summary of changes:
.../group/GroupCoordinatorRecordHelpers.java | 9 +
.../coordinator/group/GroupCoordinatorService.java | 116 ++++++---
.../coordinator/group/GroupCoordinatorShard.java | 24 ++
.../coordinator/group/GroupMetadataManager.java | 203 +++++++++++++---
.../ShareGroupStatePartitionMetadataValue.json | 2 +
.../group/GroupCoordinatorRecordHelpersTest.java | 1 +
.../group/GroupCoordinatorServiceTest.java | 167 +++++++++++--
.../group/GroupMetadataManagerTest.java | 260 ++++++++++++++++-----
.../group/GroupMetadataManagerTestContext.java | 9 +
9 files changed, 660 insertions(+), 131 deletions(-)
