ShivsundarR commented on code in PR #19369:
URL: https://github.com/apache/kafka/pull/19369#discussion_r2030220644
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java:
##########
@@ -937,7 +938,7 @@ private void sendAcknowledgementsAndLeaveGroup(final Timer
timer, final AtomicRe
// If users have fatal error, they will get some exceptions in the
background queue.
// When running unsubscribe, these exceptions should be ignored,
or users can't unsubscribe successfully.
processBackgroundEvents(unsubscribeEvent.future(), timer, e -> (e
instanceof GroupAuthorizationException
- || e instanceof TopicAuthorizationException));
+ || e instanceof TopicAuthorizationException || e instanceof
InvalidTopicException));
Review Comment:
Thanks, I have added now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
