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));

Reply via email to