chia7712 commented on code in PR #16449:
URL: https://github.com/apache/kafka/pull/16449#discussion_r1666864664
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##########
@@ -1490,6 +1490,8 @@ public void unsubscribe() {
log.error("Failed while waiting for the unsubscribe event
to complete");
}
resetGroupMetadata();
+ } else {
Review Comment:
@FrankYang0529 Please take a look at @lianetm comments:
> we would have to end up calling the subcriptionState.unsubscribe from the
ApplicationEventProcessor where we process(UnsubscribeEvent). We wouldn't be
able to reuse the MembershipMgr logic (which is part of what I had in mind when
commenting on the jira), because if there is no groupId we don't even have an
instance of the MembershipMgr.
--
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
