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 82ea9d0fcef MINOR : Handle error for client telemetry push (#19881)
add 2977cb17d02 KAFKA-17747: [6/N] Replace subscription metadata with
metadata hash in share group (#19796)
No new revisions were added by this update.
Summary of changes:
.../group/GroupCoordinatorRecordHelpers.java | 48 -----
.../coordinator/group/GroupCoordinatorShard.java | 9 -
.../coordinator/group/GroupMetadataManager.java | 111 ++++------
.../coordinator/group/modern/ModernGroup.java | 59 ------
.../coordinator/group/modern/TopicMetadata.java | 132 ------------
.../coordinator/group/modern/share/ShareGroup.java | 1 -
.../message/ShareGroupPartitionMetadataKey.json | 27 ---
.../message/ShareGroupPartitionMetadataValue.json | 41 ----
.../apache/kafka/coordinator/group/Assertions.java | 25 ---
.../group/GroupMetadataManagerTest.java | 84 +++++---
.../group/GroupMetadataManagerTestContext.java | 9 -
.../group/OffsetMetadataManagerTest.java | 9 -
.../group/modern/TopicMetadataTest.java | 69 -------
.../group/modern/consumer/ConsumerGroupTest.java | 229 ---------------------
.../group/modern/share/ShareGroupBuilder.java | 31 +--
.../group/modern/share/ShareGroupTest.java | 229 ---------------------
.../tools/consumer/ShareGroupMessageFormatter.java | 1 -
.../consumer/ShareGroupMessageFormatterTest.java | 31 ---
18 files changed, 95 insertions(+), 1050 deletions(-)
delete mode 100644
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TopicMetadata.java
delete mode 100644
group-coordinator/src/main/resources/common/message/ShareGroupPartitionMetadataKey.json
delete mode 100644
group-coordinator/src/main/resources/common/message/ShareGroupPartitionMetadataValue.json
delete mode 100644
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TopicMetadataTest.java
