This is an automated email from the ASF dual-hosted git repository. frankvicky pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new 202e216a609 MINOR: Cleanup hasMemberSubscriptionChanged (#20047) 202e216a609 is described below commit 202e216a609b59acdca38668a59191ee6f6490e5 Author: David Jacot <david.ja...@gmail.com> AuthorDate: Fri Jun 27 08:16:49 2025 +0200 MINOR: Cleanup hasMemberSubscriptionChanged (#20047) Cleanup hasMemberSubscriptionChanged. Remove unused InvalidRegularExpressionException from the signature. Reviewers: Sean Quah <sq...@confluent.io>, Chia-Ping Tsai <chia7...@gmail.com>, TengYao Chi <frankvi...@apache.org> --- .../java/org/apache/kafka/coordinator/group/GroupMetadataManager.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java index 9c9500485b1..0879283931a 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java @@ -27,7 +27,6 @@ import org.apache.kafka.common.errors.GroupIdNotFoundException; import org.apache.kafka.common.errors.GroupMaxSizeReachedException; import org.apache.kafka.common.errors.IllegalGenerationException; import org.apache.kafka.common.errors.InconsistentGroupProtocolException; -import org.apache.kafka.common.errors.InvalidRegularExpression; import org.apache.kafka.common.errors.InvalidRequestException; import org.apache.kafka.common.errors.RebalanceInProgressException; import org.apache.kafka.common.errors.UnknownMemberIdException; @@ -3036,14 +3035,13 @@ public class GroupMetadataManager { * @param records The list to accumulate any new records. * @return A boolean indicating whether the updatedMember has a different * subscribedTopicNames from the old member. - * @throws InvalidRegularExpression if the regular expression is invalid. */ private boolean hasMemberSubscriptionChanged( String groupId, ConsumerGroupMember member, ConsumerGroupMember updatedMember, List<CoordinatorRecord> records - ) throws InvalidRegularExpression { + ) { String memberId = updatedMember.memberId(); if (!updatedMember.equals(member)) { records.add(newConsumerGroupMemberSubscriptionRecord(groupId, updatedMember));