This is an automated email from the ASF dual-hosted git repository. cadonna pushed a commit to branch kip1071 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit c7deec0e70c25b9367f25d3a150ebdac26aeede1 Author: Bruno Cadonna <[email protected]> AuthorDate: Thu Nov 28 14:08:46 2024 +0100 Remove superfluous record version --- .../org/apache/kafka/coordinator/group/GroupCoordinatorShard.java | 7 ------- 1 file changed, 7 deletions(-) diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java index 4af85ad97c9..414f23aab67 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java @@ -946,13 +946,6 @@ public class GroupCoordinatorShard implements CoordinatorShard<CoordinatorRecord ); break; - case 15: - groupMetadataManager.replay( - (ConsumerGroupRegularExpressionKey) key.message(), - (ConsumerGroupRegularExpressionValue) Utils.messageOrNull(value) - ); - break; - case 16: groupMetadataManager.replay( (ConsumerGroupRegularExpressionKey) key.message(),
