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 records - ) throws InvalidRegularExpression { + ) { String memberId = updatedMember.memberId(); if (!updatedMember.equals(member)) { records.add(newConsumerGroupMemberSubscriptionRecord(groupId, updatedMember));